diff options
| author | Sam Morrison <sorrison@gmail.com> | 2012-10-26 09:53:06 +1100 |
|---|---|---|
| committer | Sam Morrison <sorrison@gmail.com> | 2012-10-26 09:58:03 +1100 |
| commit | 46944e3bf401be4f6d3af0b5d8e1e5686fdbec61 (patch) | |
| tree | eb62c8d1c7b0743af04600beb1d6d93d21d1c25a /openstack/common/rpc | |
| parent | d887090b5a31672e4a12f302b3818e2b0933bef0 (diff) | |
| download | oslo-46944e3bf401be4f6d3af0b5d8e1e5686fdbec61.tar.gz oslo-46944e3bf401be4f6d3af0b5d8e1e5686fdbec61.tar.xz oslo-46944e3bf401be4f6d3af0b5d8e1e5686fdbec61.zip | |
Use queue_arguments for fanout consumers too.
Fixes bug 1071528
queue_arguments (currently only x-ha-policy for now) were only
set for topic consumers, this adds support for rabbit HA for
fanout consumers too.
Change-Id: I0d5c0393b49cf249262d93a64f6348caa76ef8dd
Diffstat (limited to 'openstack/common/rpc')
| -rw-r--r-- | openstack/common/rpc/impl_kombu.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/openstack/common/rpc/impl_kombu.py b/openstack/common/rpc/impl_kombu.py index fc34de1..a44a000 100644 --- a/openstack/common/rpc/impl_kombu.py +++ b/openstack/common/rpc/impl_kombu.py @@ -267,6 +267,7 @@ class FanoutConsumer(ConsumerBase): # Default options options = {'durable': False, + 'queue_arguments': _get_queue_arguments(conf), 'auto_delete': True, 'exclusive': True} options.update(kwargs) |