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/amqp.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/amqp.py')
-rw-r--r-- | openstack/common/rpc/amqp.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/openstack/common/rpc/amqp.py b/openstack/common/rpc/amqp.py index 22e01d7..1ab7ae4 100644 --- a/openstack/common/rpc/amqp.py +++ b/openstack/common/rpc/amqp.py @@ -151,11 +151,13 @@ class ConnectionContext(rpc_common.Connection): def create_worker(self, topic, proxy, pool_name): self.connection.create_worker(topic, proxy, pool_name) - def join_consumer_pool(self, callback, pool_name, topic, exchange_name): + def join_consumer_pool(self, callback, pool_name, topic, exchange_name, + ack_on_error=True): self.connection.join_consumer_pool(callback, pool_name, topic, - exchange_name) + exchange_name, + ack_on_error) def consume_in_thread(self): self.connection.consume_in_thread() |