From 5e667284c5060d1b2626fc4928d73735e3911b8e Mon Sep 17 00:00:00 2001
From: Serg Melikyan <smelikyan@mirantis.com>
Date: Thu, 17 Oct 2013 08:57:20 +0400
Subject: [PATCH] Added support for HA (mirrored-queues)

Change-Id: Ibde55e74346972cc4f0ea558a759d75585f3f063
---
 muranocommon/messaging/mqclient.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/muranocommon/messaging/mqclient.py b/muranocommon/messaging/mqclient.py
index 544361e..bf8c271 100644
--- a/muranocommon/messaging/mqclient.py
+++ b/muranocommon/messaging/mqclient.py
@@ -60,7 +60,9 @@ class MqClient(object):
             self._connected = False
 
     def declare(self, queue, exchange=None):
-        promise = self._client.queue_declare(str(queue), durable=True)
+        promise = self._client.queue_declare(
+            str(queue), durable=True, arguments={'x-ha-policy': 'all'}
+        )
         self._client.wait(promise)
 
         if exchange: