Merge "reject when skipping failed messages"
This commit is contained in:
commit
1242564e4d
@ -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