From 9939a3f430c2a8e1386628da9c33344295e9951a Mon Sep 17 00:00:00 2001 From: YuehuCao Date: Wed, 17 Sep 2025 13:32:28 +0800 Subject: [PATCH] fix(exclude): ban the exclusive mode --- apps/notification/backend/infra/rabbitmq/async_subscriber.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/apps/notification/backend/infra/rabbitmq/async_subscriber.py b/apps/notification/backend/infra/rabbitmq/async_subscriber.py index 0820d31..66dc1d3 100644 --- a/apps/notification/backend/infra/rabbitmq/async_subscriber.py +++ b/apps/notification/backend/infra/rabbitmq/async_subscriber.py @@ -39,7 +39,7 @@ class AsyncMQSubscriber(AsyncMQClient): try: await self.bind(max_retries=5, event_loop=event_loop) await self.queue.consume( - no_ack=False, exclusive=True, callback=self.process_incoming_message + no_ack=False, exclusive=False, callback=self.process_incoming_message ) break # Exit loop if subscription is successful except Exception as e: