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

Merge pull request 'fix(exclude): ban the exclusive mode' (#49) from tania_local into dev

Browse Source 
Reviewed-on: freeleaps/freeleaps-service-hub#49
This commit is contained in:
icecheng 2025-09-17 05:48:56 +00:00
commit be2acb5c87
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: