From 46944e3bf401be4f6d3af0b5d8e1e5686fdbec61 Mon Sep 17 00:00:00 2001 From: Sam Morrison Date: Fri, 26 Oct 2012 09:53:06 +1100 Subject: Use queue_arguments for fanout consumers too. Fixes bug 1071528 queue_arguments (currently only x-ha-policy for now) were only set for topic consumers, this adds support for rabbit HA for fanout consumers too. Change-Id: I0d5c0393b49cf249262d93a64f6348caa76ef8dd --- openstack/common/rpc/impl_kombu.py | 1 + 1 file changed, 1 insertion(+) (limited to 'openstack') diff --git a/openstack/common/rpc/impl_kombu.py b/openstack/common/rpc/impl_kombu.py index fc34de1..a44a000 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) -- cgit