diff --git a/apps/notification/backend/infra/rabbitmq/async_client.py b/apps/notification/backend/infra/rabbitmq/async_client.py index 4b5c929..2387125 100644 --- a/apps/notification/backend/infra/rabbitmq/async_client.py +++ b/apps/notification/backend/infra/rabbitmq/async_client.py @@ -25,7 +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), loop=event_loop, ) self.channel = await self.connection.channel() diff --git a/apps/notification/common/config/app_settings.py b/apps/notification/common/config/app_settings.py index 620d05c..ec72713 100644 --- a/apps/notification/common/config/app_settings.py +++ b/apps/notification/common/config/app_settings.py @@ -8,6 +8,9 @@ class AppSettings(BaseSettings): RABBITMQ_HOST: str = "" RABBITMQ_PORT: int = 5672 + RABBITMQ_USERNAME: str = "" + RABBITMQ_PASSWORD: str = "" + RABBITMQ_VIRTUAL_HOST: str = "" SYSTEM_USER_ID: str = "" SMS_FROM: str = ""