diff options
| -rw-r--r-- | taskflow/engines/worker_based/dispatcher.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/taskflow/engines/worker_based/dispatcher.py b/taskflow/engines/worker_based/dispatcher.py index dc4819b..1733df8 100644 --- a/taskflow/engines/worker_based/dispatcher.py +++ b/taskflow/engines/worker_based/dispatcher.py @@ -97,6 +97,9 @@ class TypeDispatcher(object): LOG.debug("AMQP message %r acknowledged.", message.delivery_tag) handler(data, message) + else: + message.reject_log_error(logger=LOG, + errors=(kombu_exc.MessageStateError,)) def on_message(self, data, message): """This method is called on incoming messages.""" |