diff options
| author | Jenkins <jenkins@review.openstack.org> | 2013-01-03 08:06:09 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2013-01-03 08:06:09 +0000 |
| commit | db06b3c75286adac8c6b3e21347f6cf14cbc5978 (patch) | |
| tree | 61083ab185f705094d68d539edf787607ac95a6a /openstack/common | |
| parent | bf5e64a754abfc2edd1c25094e591817be4b762c (diff) | |
| parent | c51e68136903bbfa8275185a1656f6f5a3ebd2b6 (diff) | |
| download | oslo-db06b3c75286adac8c6b3e21347f6cf14cbc5978.tar.gz oslo-db06b3c75286adac8c6b3e21347f6cf14cbc5978.tar.xz oslo-db06b3c75286adac8c6b3e21347f6cf14cbc5978.zip | |
Merge "Don't use exclusive queues for fanout and direct"
Diffstat (limited to 'openstack/common')
| -rw-r--r-- | openstack/common/rpc/impl_kombu.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/openstack/common/rpc/impl_kombu.py b/openstack/common/rpc/impl_kombu.py index ced4e96..668d9b6 100644 --- a/openstack/common/rpc/impl_kombu.py +++ b/openstack/common/rpc/impl_kombu.py @@ -196,7 +196,7 @@ class DirectConsumer(ConsumerBase): # Default options options = {'durable': False, 'auto_delete': True, - 'exclusive': True} + 'exclusive': False} options.update(kwargs) exchange = kombu.entity.Exchange(name=msg_id, type='direct', @@ -269,7 +269,7 @@ class FanoutConsumer(ConsumerBase): options = {'durable': False, 'queue_arguments': _get_queue_arguments(conf), 'auto_delete': True, - 'exclusive': True} + 'exclusive': False} options.update(kwargs) exchange = kombu.entity.Exchange(name=exchange_name, type='fanout', durable=options['durable'], @@ -316,7 +316,7 @@ class DirectPublisher(Publisher): options = {'durable': False, 'auto_delete': True, - 'exclusive': True} + 'exclusive': False} options.update(kwargs) super(DirectPublisher, self).__init__(channel, msg_id, msg_id, type='direct', **options) @@ -350,7 +350,7 @@ class FanoutPublisher(Publisher): """ options = {'durable': False, 'auto_delete': True, - 'exclusive': True} + 'exclusive': False} options.update(kwargs) super(FanoutPublisher, self).__init__(channel, '%s_fanout' % topic, None, type='fanout', **options) |