[rabbitmq-discuss] RabbitMq and POE::Component::Client::AMQP - Re-delivery to same client?
Simone Busoli
simone.busoli at gmail.com
Wed Dec 14 23:36:10 GMT 2011
Andy, you would have to
recover<http://www.rabbitmq.com/amqp-0-9-1-reference.html#basic.recover>the
messages.
On Thu, Dec 15, 2011 at 00:29, Andy Walker <walkeraj at gmail.com> wrote:
> So, I am playing around with the POE module in an attempt to get the hang
> of using RabbitMQ. I have written two programs, a producer and a consumer
> that operate on a single, persistent queue. Everything seems to work, save
> for one thing: In order to simulate failure, I have written the consumer
> to randomly not ack the messages it receives. The problem is that the
> server does not seem to be re-delivering these messages. If I kill and
> restart the consumer, it receives all of the messages it didn't ack. If I
> leave it running, however, they never seem to be re-sent. This concerns me
> because, if I have five consumers running, and they all kick back a failure
> on the same message (unlikely, yes, but possible), what happens to the
> message? Does it stay undelivered forever? How do I solve this problem?
>
> Code is here: http://pastie.org/3017289
>
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20111215/d5a4d78a/attachment.htm>
More information about the rabbitmq-discuss
mailing list