stackforge-attic/murano-common
Code Issues Proposed changes

Merge "Added support for HA (mirrored-queues)" into release-0.3

Browse Source
This commit is contained in:
Jenkins 2013-10-17 04:59:16 +00:00 committed by Gerrit Code Review
commit d2ffd0ba74
1 changed files with 3 additions and 1 deletions

4
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: