Skip to content

Commit 7919bf6

Browse files
m-karoVeikoAunapuu
authored andcommitted
bugfix: rmq consumer stop all handlers if one failes
1 parent 28a9b5f commit 7919bf6

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

emf/common/integrations/rabbit.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -397,6 +397,8 @@ def _process_messages(self, basic_deliver, properties, body):
397397
logger.error(f"Message handling failed: {error}", exc_info=True)
398398
ack = False
399399
self._channel.basic_reject(basic_deliver.delivery_tag, requeue=True)
400+
logger.error(f"Message rejected due to handler error")
401+
break
400402
# self.connection.close()
401403
# self.stop()
402404

0 commit comments

Comments
 (0)