diff options
| author | Jenkins <jenkins@review.openstack.org> | 2013-06-24 21:27:10 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2013-06-24 21:27:10 +0000 |
| commit | bc10b7aeada4ea66e85e10b94b5c219e3c8d2e77 (patch) | |
| tree | 401cb3970168f27af98ca5d7f3d2a60bad0b0255 /openstack/common/rpc/impl_qpid.py | |
| parent | e177a47c8397b6285ffc4ef877280ec550b71e4e (diff) | |
| parent | e204885a907c6cca79f8504a942006cdb737bb28 (diff) | |
| download | oslo-bc10b7aeada4ea66e85e10b94b5c219e3c8d2e77.tar.gz oslo-bc10b7aeada4ea66e85e10b94b5c219e3c8d2e77.tar.xz oslo-bc10b7aeada4ea66e85e10b94b5c219e3c8d2e77.zip | |
Merge "Optionally reject messages on exception."
Diffstat (limited to 'openstack/common/rpc/impl_qpid.py')
| -rw-r--r-- | openstack/common/rpc/impl_qpid.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/openstack/common/rpc/impl_qpid.py b/openstack/common/rpc/impl_qpid.py index 7352517..46dcb6a 100644 --- a/openstack/common/rpc/impl_qpid.py +++ b/openstack/common/rpc/impl_qpid.py @@ -152,6 +152,7 @@ class ConsumerBase(object): except Exception: LOG.exception(_("Failed to process message... skipping it.")) finally: + # TODO(sandy): Need support for optional ack_on_error. self.session.acknowledge(message) def get_receiver(self): @@ -615,7 +616,7 @@ class Connection(object): return consumer def join_consumer_pool(self, callback, pool_name, topic, - exchange_name=None): + exchange_name=None, ack_on_error=True): """Register as a member of a group of consumers for a given topic from the specified exchange. |