[rabbitmq-discuss] Pika add x-ha-policy with nodes arguments

Sat Oct 15 07:22:25 BST 2011

Hello, I try to use HA feature with pika python client API>

But it will not success when I tried to use "nodes" instead of "all" as the
arguments in "x-ha-policy".

The code is like the following:
=======================================
    channel.queue_declare(queue="test_topic", durable=True,
                          exclusive=False, auto_delete=False,
                          arguments={'x-ha-policy': 'nodes',
'x-ha-policy-params':
                            ['rabbit at test1', 'rabbit at test2']},
                          callback=on_queue_declared)

=======================================

How do I do if I want to use "x-ha-policy" with "nodes"?

It works when I set "x-ha-policy" to "all" and I didn't use
"x-ha-policy-params" at all.

Thanks

Shen, Yu-Teh
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20111015/6f838b72/attachment.htm>