Skip to content

Commit 4f7d81a

Browse files
committed
Update servicebus_service.py
1 parent f4b1015 commit 4f7d81a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/services/servicebus_service.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ def __new__(cls):
2929
def __init__(self) -> None:
3030
self.config = Config()
3131
self.core = Core()
32-
self.incoming_topic = self.core.get_topic(self.config.incoming_topic_name)
32+
self.incoming_topic = self.core.get_topic(self.config.incoming_topic_name, self.config.max_concurrent_messages)
3333
self.outgoing_topic = self.core.get_topic(self.config.outgoing_topic_name)
3434
self.storage_service = StorageService(self.core)
3535
self.listening_thread = threading.Thread(target=self.incoming_topic.subscribe, args=[self.config.incoming_topic_subscription, self.process_message])

0 commit comments

Comments
 (0)