From 568e533c3accb15d01bf6a8ebbf600a68b920916 Mon Sep 17 00:00:00 2001
From: Kei Masumoto <masumotok@nttdata.co.jp>
Date: Wed, 13 Feb 2013 23:20:26 +0900
Subject: Fix "DirectConsumer needs mirrored queue support"

Currently TopicCosumer and FanoutConsumer can be used
Mirrored Queue support, but not DirectConsumer.
This patch fix this issue.

Fix bug 1124162

Change-Id: I68ae23467ae810ce0ec917a4cb34a488283f401c
---
 openstack/common/rpc/impl_kombu.py | 1 +
 1 file changed, 1 insertion(+)

(limited to 'openstack/common/rpc/impl_kombu.py')

diff --git a/openstack/common/rpc/impl_kombu.py b/openstack/common/rpc/impl_kombu.py
index 4f3cc7a..c827a68 100644
--- a/openstack/common/rpc/impl_kombu.py
+++ b/openstack/common/rpc/impl_kombu.py
@@ -197,6 +197,7 @@ class DirectConsumer(ConsumerBase):
         """
         # Default options
         options = {'durable': False,
+                   'queue_arguments': _get_queue_arguments(conf),
                    'auto_delete': True,
                    'exclusive': False}
         options.update(kwargs)
-- 
cgit