Added support for HA (mirrored-queues)

Change-Id: Ibde55e74346972cc4f0ea558a759d75585f3f063
2013-10-17 08:57:20 +04:00 · 2013-10-17 08:57:20 +04:00 · 5e667284c5
commit 5e667284c5
parent 0349d3ba7b
1 changed files with 3 additions and 1 deletions
--- 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: