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()