icecheng/freeleaps-service-hub
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(exclude): ban the exclusive mode

Browse Source
This commit is contained in:
YuehuCao 2025-09-17 13:32:28 +08:00
parent 3301aec1d5
commit 9939a3f430
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/notification/backend/infra/rabbitmq/async_subscriber.py
View File

@ -39,7 +39,7 @@ class AsyncMQSubscriber(AsyncMQClient):
try: try:
await self.bind(max_retries=5, event_loop=event_loop) await self.bind(max_retries=5, event_loop=event_loop)
await self.queue.consume( 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 break # Exit loop if subscription is successful
except Exception as e: except Exception as e: