This commit is contained in:
parent
d2586defda
commit
5d1b680ae3
@ -266,7 +266,7 @@ class RabbitMQConsumer:
|
|||||||
logger.error(f"[RabbitMQ] Error processing delivery validation for uuid={uuid}: {e}", exc_info=True)
|
logger.error(f"[RabbitMQ] Error processing delivery validation for uuid={uuid}: {e}", exc_info=True)
|
||||||
try:
|
try:
|
||||||
await self.send_message_to_dlq(uuid,message)
|
await self.send_message_to_dlq(uuid,message)
|
||||||
except Exception as dlQ_error:
|
except Exception as dlq_error:
|
||||||
logger.error(f"[RabbitMQ] Failed to send to DLQ for uuid={uuid}: {dlq_error}")
|
logger.error(f"[RabbitMQ] Failed to send to DLQ for uuid={uuid}: {dlq_error}")
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user