[rabbitmq-discuss] Recycling messages that have been consumed but not acked

Marek Majkowski majek04 at gmail.com
Fri Sep 2 10:34:24 BST 2011


On Thu, Sep 1, 2011 at 06:30, Dmitry Demeshchuk <demeshchuk at gmail.com> wrote:
> Looks like basic.recover is what I want, right?

Yes, looks like it:
http://www.rabbitmq.com/amqp-0-9-1-quickref.html#basic.recover


> On Thu, Sep 1, 2011 at 9:24 AM, Dmitry Demeshchuk <demeshchuk at gmail.com> wrote:
>> Hello,
>>
>> We have an Erlang application that uses multiple nodes each with
>> several rabbitmq consumers connected to different queues. When a node
>> goes down, its consumers are rebalanced among the rest running nodes.
>>
>> However, there's a problem. It may take minutes between message
>> consumption and acking, so most likely when a node goes down, there
>> are some messages that have been consumed but haven't been acked. And
>> seems like in that case the newly spawned consumers that are
>> rebalanced to the other nodes don't get those unacked messages, since
>> they are already considered to be consumed.
>>
>> So, my question is, is there a way to make all unacked messages in a
>> queue become ready for consumption again?
>>
>> Thank you.
>>
>> --
>> Best regards,
>> Dmitry Demeshchuk
>>
>
>
>
> --
> Best regards,
> Dmitry Demeshchuk
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>


More information about the rabbitmq-discuss mailing list