diff --git a/src/services/servicebus_service.py b/src/services/servicebus_service.py
index 3de184a..fc7d341 100644
--- a/src/services/servicebus_service.py
+++ b/src/services/servicebus_service.py
@@ -29,7 +29,7 @@ def __new__(cls):
     def __init__(self) -> None:
         self.config = Config()
         self.core = Core()
-        self.incoming_topic = self.core.get_topic(self.config.incoming_topic_name)
+        self.incoming_topic = self.core.get_topic(self.config.incoming_topic_name, self.config.max_concurrent_messages)
         self.outgoing_topic = self.core.get_topic(self.config.outgoing_topic_name)
         self.storage_service = StorageService(self.core)
         self.listening_thread = threading.Thread(target=self.incoming_topic.subscribe, args=[self.config.incoming_topic_subscription, self.process_message])