[rabbitmq-discuss] RabbitMQ HA queue declaration fail

Sat Oct 15 10:11:44 BST 2011

Hello, I got the following error when I tried to declare mirror-queue with
"nodes" on "x-ha-policy" argument.

I have run cluster with 3 nodes from rabbit at lab001 to lab003.

I run the following java code.
============================================
           Connection conn = test.CreateConn("guest", "guest", "/test",
"127.0.0.1", 5672);
            Channel chl = conn.createChannel();
            chl.exchangeDeclare(exchangeName, "direct", true);

            Map<String, Object> args = new HashMap<String, Object>();
            args.put("x-ha-policy", "nodes");
            args.put("x-ha-policy-params", Arrays.asList("rabbit at lab001",
"rabbit at lab002"));
            chl.queueDeclare(queueName, false, false, false, args);
            chl.queueBind(queueName, exchangeName, routingKey);

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

=ERROR REPORT==== 15-Oct-2011::15:46:07 ===
** Generic server <0.6599.4> terminating
** Last message in was {init,false}
** When Server state == {q,{amqqueue,

 {resource,<<"/test">>,queue,<<"test.queue2">>},
                               false,false,none,
                               [{<<"x-ha-policy-params">>,array,
                                 [{longstr,<<"rabbit at lab001">>},
                                  {longstr,<<"rabbit at lab002">>}]},
                                {<<"x-ha-policy">>,longstr,<<"nodes">>}],
                               <0.6599.4>,[],
                               [rabbit at lab002]},
                           none,false,rabbit_mirror_queue_master,undefined,
                           {[],[]},
                           {[],[]},
                           undefined,undefined,undefined,undefined,
                           {state,fine,5000,undefined},
                           {dict,0,16,16,8,80,48,

 {[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                []},

 {{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                 []}}},
                           undefined,undefined}
** Reason for termination ==
** {badarg,[{erlang,binary_to_list,[rabbit at lab002]},
            {rabbit_mirror_queue_master,'-init/3-lc$^0/1-0-',1},
            {rabbit_mirror_queue_master,init,3},
            {rabbit_amqqueue_process,declare,3},
            {gen_server2,handle_msg,2},
            {proc_lib,init_p_do_apply,3}]}

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