diff options
| author | Jenkins <jenkins@review.openstack.org> | 2012-10-30 22:16:24 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2012-10-30 22:16:24 +0000 |
| commit | ae6f54dba69449eb1c231de162c12711bd2ab528 (patch) | |
| tree | 63288c03e928a3f5eeb20e58042279414681a18f /openstack/common/rpc/impl_kombu.py | |
| parent | 999f946d08714dc12469310e3dceed78d588e153 (diff) | |
| parent | 46944e3bf401be4f6d3af0b5d8e1e5686fdbec61 (diff) | |
| download | oslo-ae6f54dba69449eb1c231de162c12711bd2ab528.tar.gz oslo-ae6f54dba69449eb1c231de162c12711bd2ab528.tar.xz oslo-ae6f54dba69449eb1c231de162c12711bd2ab528.zip | |
Merge "Use queue_arguments for fanout consumers too."
Diffstat (limited to 'openstack/common/rpc/impl_kombu.py')
| -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 e9118d6..eccb7ab 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) |