This commit is contained in:
1 parent
52a6015ea0
commit
e602963d85
1 file changed
+1
-1
@@ -63,7 +63,7 @@ class RabbitMQProducer:
|
||||
mandatory=True
|
||||
)
|
||||
logger.debug(f"[RabbitMQ] Successfully published to notify.user.{routing_key}")
|
||||
except (AMQPException, ConnectionError, OSError) as e:
|
||||
except (AMQPException, OSError) as e:
|
||||
logger.warning(f"[RabbitMQ] Publish failed, requeuing message: {e}", exc_info=True)
|
||||
await asyncio.sleep(2)
|
||||
await self._queue.put((routing_key, message))
|
||||
|
||||
Reference in new issue
Block a user