From 853d81793332513e89286d61429444d520252c27 Mon Sep 17 00:00:00 2001 From: zhenyus Date: Mon, 24 Feb 2025 02:05:25 +0800 Subject: [PATCH] feat(notification): add rabbitmq credentials relates notification services configs Signed-off-by: zhenyus --- apps/notification/backend/infra/rabbitmq/async_client.py | 5 ++++- apps/notification/common/config/app_settings.py | 3 +++ 2 files changed, 7 insertions(+), 1 deletion(-) 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 = ""