diff options
| author | Jenkins <jenkins@review.openstack.org> | 2013-02-20 01:38:37 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2013-02-20 01:38:37 +0000 |
| commit | a1cc88f63228ab42d1cf7958c0989c7d7d4b1ef2 (patch) | |
| tree | d2ba05054598145a9cbfd4aec8548e50398e26ab /openstack | |
| parent | 9e51e9a431b406d637183fd0d89c80f9ad52d061 (diff) | |
| parent | 568e533c3accb15d01bf6a8ebbf600a68b920916 (diff) | |
| download | oslo-a1cc88f63228ab42d1cf7958c0989c7d7d4b1ef2.tar.gz oslo-a1cc88f63228ab42d1cf7958c0989c7d7d4b1ef2.tar.xz oslo-a1cc88f63228ab42d1cf7958c0989c7d7d4b1ef2.zip | |
Merge "Fix "DirectConsumer needs mirrored queue support""
Diffstat (limited to 'openstack')
| -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 fb5d16f..91d81b0 100644 --- a/openstack/common/rpc/impl_kombu.py +++ b/openstack/common/rpc/impl_kombu.py @@ -218,6 +218,7 @@ class DirectConsumer(ConsumerBase): """ # Default options options = {'durable': False, + 'queue_arguments': _get_queue_arguments(conf), 'auto_delete': True, 'exclusive': False} options.update(kwargs) |