Skip to content

Commit 9a86e2c

Browse files
authored
Merge branch 'main' into dev
2 parents eca95dc + 853d642 commit 9a86e2c

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
@@ -392,6 +392,7 @@ def _process_messages(self, basic_deliver, properties, body):
392392
for message_handler in self.message_handlers:
393393
logger.info(f"Handling message with handler: {message_handler.__class__.__name__}")
394394
body, properties = message_handler.handle(body, properties=properties, channel=self._channel)
395+
395396
except Exception as error:
396397
logger.error(f"Message handling failed: {error}", exc_info=True)
397398
ack = False
@@ -401,6 +402,7 @@ def _process_messages(self, basic_deliver, properties, body):
401402
# self.connection.close()
402403
# self.stop()
403404

405+
404406
# Process message acknowledgment
405407
if ack:
406408
# Check if properties has some status flag set from handler

0 commit comments

Comments
 (0)