diff --git a/notifications_consumer/consumer.py b/notifications_consumer/consumer.py index 409966110b0e222dbe4fdf20033ebbe51436dd84..5c8b90b7c5962ac1983e129de321684218c4024c 100644 --- a/notifications_consumer/consumer.py +++ b/notifications_consumer/consumer.py @@ -41,6 +41,7 @@ class NotificationsConsumer(megabus.Listener): **self.processor.read_message(json.loads(message)), **self.kwargs ) self.ack_message(headers["message-id"]) - except Exception: - # TODO: logger.error + except Exception as e: + logging.critical(f"An exception happened while processing the message: {e}", exc_info=True) + self.nack_message(headers["message-id"])