diff options
Diffstat (limited to 'nova')
| -rw-r--r-- | nova/rpc/impl_kombu.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/nova/rpc/impl_kombu.py b/nova/rpc/impl_kombu.py index b9fb081bd..2c14087be 100644 --- a/nova/rpc/impl_kombu.py +++ b/nova/rpc/impl_kombu.py @@ -137,9 +137,10 @@ class ConsumerBase(object): message = self.channel.message_to_python(raw_message) try: callback(message.payload) - message.ack() except Exception: LOG.exception(_("Failed to process message... skipping it.")) + finally: + message.ack() self.queue.consume(*args, callback=_callback, **options) |