From 78c72179ec3fdb15d4af01bee15a441f0e383638 Mon Sep 17 00:00:00 2001 From: zhenyus Date: Mon, 24 Feb 2025 02:20:01 +0800 Subject: [PATCH] fix(rabbitmq): correct syntax for port and virtual host parameters in AsyncMQClient Signed-off-by: zhenyus --- apps/notification/backend/infra/rabbitmq/async_client.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/apps/notification/backend/infra/rabbitmq/async_client.py b/apps/notification/backend/infra/rabbitmq/async_client.py index 2387125..0df0745 100644 --- a/apps/notification/backend/infra/rabbitmq/async_client.py +++ b/apps/notification/backend/infra/rabbitmq/async_client.py @@ -25,10 +25,10 @@ class AsyncMQClient: try: self.connection = await aio_pika.connect_robust( host=app_settings.RABBITMQ_HOST, - port=int(app_settings.RABBITMQ_PORT, + port=int(app_settings.RABBITMQ_PORT), login=app_settings.RABBITMQ_USERNAME, password=app_settings.RABBITMQ_PASSWORD, - virtualhost=app_settings.RABBITMQ_VIRTUAL_HOST), + virtualhost=app_settings.RABBITMQ_VIRTUAL_HOST, loop=event_loop, ) self.channel = await self.connection.channel()