[rabbitmq-discuss] Message is delivered to all queue consumers when rabbitmq crashes

Fri Oct 21 17:53:37 BST 2011

Hi Simon,

This problem happens only if consumers run as separate processes (in
different jvms). If they all run in the same jvm everything works
fine.

Thanks,
Reza

On Oct 21, 7:37 am, Simon MacMullen <si... at rabbitmq.com> wrote:
> On 19/10/11 21:02, rasadoll wrote:
>
> > I have multiple queue consumers running at the same time. They all
> > listen to one single queue. Messages are sent to the default exchange
> > with queue name as the routing key. When one of the consumers is busy
> > processing a message, before acking the message if RabbitMQ service
> > crashes (simply by stopping the service), the message is sent to all
> > other consumers immediately which results in processing the same
> > message multiple times concurrently. Is this the right behavior for
> > RabbitMQ?
>
> No. RabbitMQ should really only deliver a given message from a queue to
> a single consumer.
>
> I haven't been able to replicate the behaviour you describe.
>
> Cheers, Simon
>
>
>
>
>
>
>
>
>
> > Here is my queue design:
>
> > Map<String, Object>  args = new HashMap<String, Object>();
> > args.put("x-ha-policy", "all");
> > channel.queueDeclare(JOB_EXEC_QUEUE, true, false, false, args);
>
> > I use durable HA queue but I am not running in a clustered
> > environment.
> > ===========================
> > Message publishing:
>
> > channel.basicPublish("", JOB_EXEC_QUEUE,
> > MessageProperties.PERSISTENT_BASIC, message.getBytes());
> > ===========================
> > Consumer Code:
>
> > channel.basicQos(1);
> > QueueingConsumer consumer = new QueueingConsumer(channel);
> > channel.basicConsume(JOB_EXEC_QUEUE, consumer);
>
> > QueueingConsumer.Delivery delivery;
> > while (true) {
> >          try {
> >            delivery = consumer.nextDelivery();
> >          } catch (InterruptedException ie) {
> >            continue;
> >          }
>
> > // process the message
>
> >         channel.basicAck(delivery.getEnvelope().getDeliveryTag(),
> > false);
> > }
>
> > I stop the service when one consumer is in the process message phase.
>
> > Am I doing something wrong? Is this an expected behavior for RabbitMQ?
>
> > Thanks,
> > Reza
> > _______________________________________________
> > rabbitmq-discuss mailing list
> > rabbitmq-disc... at lists.rabbitmq.com
> >https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
> --
> Simon MacMullen
> RabbitMQ, VMware
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-disc... at lists.rabbitmq.comhttps://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss