<div>Hello, I got the following error when I tried to declare mirror-queue with "nodes" on "x-ha-policy" argument.</div><div><br></div><div>I have run cluster with 3 nodes from rabbit@lab001 to lab003.</div>
<div><br></div><div>I run the following java code.</div><div>============================================</div><div><div> Connection conn = test.CreateConn("guest", "guest", "/test", "127.0.0.1", 5672);</div>
<div> Channel chl = conn.createChannel();</div><div> chl.exchangeDeclare(exchangeName, "direct", true);</div><div> </div><div> Map<String, Object> args = new HashMap<String, Object>();</div>
<div> args.put("x-ha-policy", "nodes");</div><div> args.put("x-ha-policy-params", Arrays.asList("rabbit@lab001", "rabbit@lab002"));</div><div> chl.queueDeclare(queueName, false, false, false, args);</div>
<div> chl.queueBind(queueName, exchangeName, routingKey);</div></div><div><br class="Apple-interchange-newline">============================================</div><div><br></div><div>=ERROR REPORT==== 15-Oct-2011::15:46:07 ===</div>
<div>** Generic server <0.6599.4> terminating</div><div>** Last message in was {init,false}</div><div>** When Server state == {q,{amqqueue,</div><div> {resource,<<"/test">>,queue,<<"test.queue2">>},</div>
<div> false,false,none,</div><div> [{<<"x-ha-policy-params">>,array,</div><div> [{longstr,<<"rabbit@lab001">>},</div>
<div> {longstr,<<"rabbit@lab002">>}]},</div><div> {<<"x-ha-policy">>,longstr,<<"nodes">>}],</div>
<div> <0.6599.4>,[],</div><div> [rabbit@lab002]},</div><div> none,false,rabbit_mirror_queue_master,undefined,</div><div> {[],[]},</div>
<div> {[],[]},</div><div> undefined,undefined,undefined,undefined,</div><div> {state,fine,5000,undefined},</div><div> {dict,0,16,16,8,80,48,</div>
<div> {[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],</div><div> []},</div><div> {{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],</div>
<div> []}}},</div><div> undefined,undefined}</div><div>** Reason for termination ==</div><div>** {badarg,[{erlang,binary_to_list,[rabbit@lab002]},</div><div> {rabbit_mirror_queue_master,'-init/3-lc$^0/1-0-',1},</div>
<div> {rabbit_mirror_queue_master,init,3},</div><div> {rabbit_amqqueue_process,declare,3},</div><div> {gen_server2,handle_msg,2},</div><div> {proc_lib,init_p_do_apply,3}]}</div>
<div><br></div><div><br></div>Shen, Yu-Teh<br>