diff --git a/api-customer/app.py b/api-customer/app.py
index 49c558e7..f8ba44b4 100644
--- a/api-customer/app.py
+++ b/api-customer/app.py
@@ -35,7 +35,9 @@ client_controller = ClientController(app, auth_data, "https://192.168.15.120:800
 message_controller = MessageController(app, auth_data, "https://192.168.15.120:8000", database_service)
 
 def handle_login(data):
-    local_broker, api_broker, forwarder = create_forwarder(data, local_broker_address, local_broker_port, api_broker_address, api_broker_port)
+    local_broker, api_broker, forwarder = create_forwarder(data,
+                         local_broker_address, local_broker_port,
+                         api_broker_address, api_broker_port, database_service)
 
     client_id = data.get_client_id()
     api_broker.subscribe(f"/chat/{client_id}/message", message_controller.handle_message_received)