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 | |
| 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
| -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) |