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: