RED-4653: Changed error case for processing messages to not requeue the message since that will be handled in DLQ logic

This commit is contained in:
Viktor Seifert 2022-07-26 10:50:42 +02:00
parent d77982dfed
commit 94648cc449

View File

@ -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