diff --git a/pyinfra/queue/queue_manager.py b/pyinfra/queue/queue_manager.py index 879e779..17a7ada 100644 --- a/pyinfra/queue/queue_manager.py +++ b/pyinfra/queue/queue_manager.py @@ -98,6 +98,7 @@ class QueueManager(object): except Exception as ex: n_attempts = _get_n_previous_attempts(properties) + 1 self.logger.warning(f"Failed to process message, {n_attempts} attempts, error: {str(ex)}") + self._channel.basic_nack(frame.delivery_tag, requeue=False) raise ex return callback