diff options
| author | Jenkins <jenkins@review.openstack.org> | 2014-09-23 00:57:22 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2014-09-23 00:57:22 +0000 |
| commit | a4f2a12dc5f6e8bb589b609dcc38ff11c16a34fa (patch) | |
| tree | 605af43d80777eb0ee6dc66a865eac254aa1ee73 | |
| parent | 1d47352b6fc511ace6eced4b7771c13d19cb50a2 (diff) | |
| parent | e389ee61d109a6b1e4908bde97547d5dbda596e3 (diff) | |
| download | taskflow-a4f2a12dc5f6e8bb589b609dcc38ff11c16a34fa.tar.gz | |
Merge "Reject WBE messages if they can't be put in an ack state"
| -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.""" |