[rabbitmq-discuss] HA Queue declaration

Fri Dec 28 14:29:58 GMT 2012

I'm currently running 2.8.7 in a cluster of 2 disk nodes and 1 ram node with a load balancer.
We have a dev and a test env pointing at the same rabbit cluster using '/dev' and '/' for vhosts.
In test we have long lived queues (per app) to start simulating our prod env and in dev we spin up auto delete queues(differing queue names based on the appVimId) to avoid the clutter of multiple people testing.
I'm trying to push HA queues out and am running into a start up error.
For /dev it works great, the app spins up the HA queues, finishes the tests and then they auto delete themselves.
When I try pushing it out to our test env I get this error from the rabbit logs:

connection <0.15043.4>, channel 1 - error:
{amqp_error,precondition_failed,
            "inequivalent arg 'x-ha-policy'for queue 'queue.name' in vhost '/': received the value 'all' of type 'longstr' but current is none",
            'queue.declare'}

I've tried pushing it out with the non HA queues still up, and also with deleting them before trying to spin up the new ones and no dice still can't create these queues.
I don't know if its worth noting that the queue names are still the same all I'm trying to do is simply declare them with the x-ha-policy = all

Map<String,Object> params = new HashMap<String, Object>();

params.put("x-ha-policy", "all");

params.put("x-expires", TimeUnit.HOURS.toMillis(24));

Queue queue = new Queue(queueName, true, false, isAutoDelete, params);

Has anyone else run into this problem? I realize I can upgrade to 3.0.1 and implement HA queues at the broker level but at this point I want to try and get this to work without having to go through and upgrade all of our envs.

Let me know if you need any more log info or code snippets or elaboration.

Thanks

-Quinn

-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20121228/4b7401d4/attachment.htm>