MessageManager initialization is async

modules/messaging/MessageManager.py

@@ -55,11 +55,12 @@ class MessageManager:
             self._receive_channel = channel
             LOGGER.info("RabbitMQ connection established")
           
-    def create_exchange_with_queue(self, exchange_name, exchange_type, queue_name):
+    def create_exchange_with_queue(self, exchange_name, exchange_type, queue_name, callback):
         '''Creates exchange and queue and binds them'''
         self._prepare_receive_parameters = {'exchange_name': exchange_name,
                                     'exchange_type': exchange_type,
-                                    'queue_name': queue_name}
+                                    'queue_name': queue_name,
+                                    'callback': callback}
         
         self._receive_channel.exchange_declare(exchange=exchange_name, exchange_type=exchange_type, callback=self._exchange_created_callback)
         
@@ -74,8 +75,11 @@ class MessageManager:
         exchange_name = self._prepare_receive_parameters['exchange_name']
         
         # Bind queue to exchange
-        self._receive_channel.queue_bind(exchange=exchange_name, queue=queue_name)
-        LOGGER.info(f"RabbitMQ connection to exchange '{exchange_name}' established")
+        self._receive_channel.queue_bind(exchange=exchange_name, queue=queue_name, callback=self._queue_bound_callback)
+
+    def _queue_bound_callback(self, _):
+        if self._prepare_receive_parameters['callback'] != None:
+            self._prepare_receive_parameters['callback']()
 
     def start_consuming(self, queue_name, auto_ack, message_received_callback):
         '''Starts listening for messages'''

modules/messaging/ReconnectingMessageManager.py

@@ -53,8 +53,12 @@ class ReconnectingMessageManager:
                                         'message_received_callback': message_received_callback}
         self._consuming = True
 
-        self._message_manager.create_exchange_with_queue(exchange_name, exchange_type, queue_name)
-        self._message_manager.start_consuming(queue_name, auto_ack, message_received_callback)
+        self._message_manager.create_exchange_with_queue(exchange_name, exchange_type, queue_name, self._exchange_created_callback)
+    
+    def _exchange_created_callback(self):
+        self._message_manager.start_consuming(self._consumption_parameters['queue_name'], 
+            self._consumption_parameters['auto_ack'], 
+            self._consumption_parameters['message_received_callback'])
 
     def create_message_destination(self, exchange_name, exchange_type):
         '''Creates the exchange'''