feat #58 - publish docker image with demo app, fix test case

amqp/service/amq_service.py

@@ -157,7 +157,7 @@ class AMQService:
 
     async def reinitialize_if_disconnected(self):
         if not self.rabbit_mq_client.channel or self.rabbit_mq_client.channel.is_closed:
-            self.rabbit_mq_client = RabbitMQClient(self.amq_configuration)
+            self.rabbit_mq_client = RabbitMQClient(self.amq_configuration, self.router)
             await self.rabbit_mq_client.init(loop=self.loop)
             await self.register_routes()
             await self.rabbit_mq_client.request_routes()

tests/rabbitmq/test_rabbit_mq_client.py

@@ -13,10 +13,10 @@ class TestRabbitMQClient(IsolatedAsyncioTestCase):
         self.mock_config.dispatch.rabbit_mq_user = "user"
         self.mock_config.dispatch.rabbit_mq_password = "pass"
         self.mock_config.dispatch.use_dlq = False
-        patcher = patch("amqp.rabbitmq.rabbit_mq_client.RouterConsumer")
+        patcher = patch("amqp.router.router_consumer.RouterConsumer")
         self.addCleanup(patcher.stop)
         self.mock_router = patcher.start()
-        self.client = RabbitMQClient(self.mock_config)
+        self.client = RabbitMQClient(self.mock_config, self.mock_router)
 
     async def test_init_sets_up_channel_and_reply_exchange(self):
         """Test that init sets up the channel, reply queue, and reply exchange."""