diff options
| author | Vishvananda Ishaya <vishvananda@gmail.com> | 2012-12-28 15:14:50 -0800 |
|---|---|---|
| committer | Vishvananda Ishaya <vishvananda@gmail.com> | 2012-12-28 15:17:26 -0800 |
| commit | c51e68136903bbfa8275185a1656f6f5a3ebd2b6 (patch) | |
| tree | 38f87b6c6288524f1c74dad09c54f9ba7a5e2fd9 /openstack/common/rpc/impl_kombu.py | |
| parent | 8888ad0126f25c91b90f7bc4c2440da0bf35ec1d (diff) | |
| download | oslo-c51e68136903bbfa8275185a1656f6f5a3ebd2b6.tar.gz oslo-c51e68136903bbfa8275185a1656f6f5a3ebd2b6.tar.xz oslo-c51e68136903bbfa8275185a1656f6f5a3ebd2b6.zip | |
Don't use exclusive queues for fanout and direct
The use of exclusive queues can cause issues on reconnect if the
rabbit server hasn't deleted the queue already. We might as well
use exclusive=False so that we can reconnect to the queue if
necessary.
Fixes bug 1094358
Change-Id: I35bd903737d6054e8856b0003b0b8af97fd21c91
Diffstat (limited to 'openstack/common/rpc/impl_kombu.py')
| -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) |