reject when skipping failed messages
reject is a more accurate action when we are tossing away messages we cannot handle. Change-Id: I7f40ac8809f93afb8e518f236d0ddf64a3b241eb
This commit is contained in:
parent
ea61a81014
commit
85b05a7f2f
@ -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):
|
||||
|
Loading…
x
Reference in New Issue
Block a user