diff --git a/oslo_messaging/_drivers/impl_rabbit.py b/oslo_messaging/_drivers/impl_rabbit.py index cfcbcd63e..11b1bae99 100644 --- a/oslo_messaging/_drivers/impl_rabbit.py +++ b/oslo_messaging/_drivers/impl_rabbit.py @@ -366,7 +366,7 @@ class Consumer(object): except Exception: LOG.exception(_LE("Failed to process message" " ... skipping it.")) - message.ack() + message.reject() class DummyConnectionLock(_utils.DummyLock):