From 2ab2509a55c3c1a05abec75e63c4cff5f3edc0e7 Mon Sep 17 00:00:00 2001 From: Stanislav Hejny Date: Tue, 1 Jul 2025 22:48:22 +0100 Subject: [PATCH] feat #58 - publish docker image with demo app, fix test case --- amqp/service/amq_service.py | 2 +- tests/rabbitmq/test_rabbit_mq_client.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/amqp/service/amq_service.py b/amqp/service/amq_service.py index acd9672..a6bf2d6 100644 --- a/amqp/service/amq_service.py +++ b/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() diff --git a/tests/rabbitmq/test_rabbit_mq_client.py b/tests/rabbitmq/test_rabbit_mq_client.py index 65da09e..7cfae4e 100644 --- a/tests/rabbitmq/test_rabbit_mq_client.py +++ b/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."""