[rabbitmq-discuss] [rabbitmq-erlang-client] Missing 1 queue message after nodedown message from another node.

[Abhinav Jha]

Hi Robert !

Thanks for your reply. However I'm currently doing nothing in the nodedown
code, simply printing a diagnostic message. I do most of the reconnection
in the nodeup message. However that reconnection code is with node B which
doesn't have anything to do with the RabbitMQ connection at all, but a
third process.

Also, I found that recompiling everything ( my app, rebar and
 rabbitmq-server, rabbitmq-erlang-client ) with erlang v 14b04 ( as opposed
to erlang 15b ) fixed this problem for me. I dont know why though. I'll
perform some more tests on another machine and update here in about a week
or so..

Thanks,
Abhinav

On Mon, Mar 12, 2012 at 2:07 PM, Robert Raschke <rtrlists at googlemail.com>wrote:

>
> On Fri, Mar 9, 2012 at 6:58 PM, Abhinav Jha <virolord at gmail.com> wrote:
>
>> Hi,
>>
>> I have a small OTP App ( say node A), that subscribes to a RabbitMQ
>> queue, and also talks to another erlang node in another process ( node B ).
>>
>> Now, sometimes the process hosting node B crashes for some reason, and my
>> node A gets a 'nodedown' message. Up till this point, consumption from
>> RabbitMQ works perfectly.
>>
>> However, after my handle_info has finished processing the nodedown, if I
>> publish a message to the RabbitMQ queue, my app doesn't consume it.
>> However, all messages published after this one are consumed properly and
>> processed. However that 1 message remains in a message_unacknowledged state
>> in the queue, even though my handle_info refuses to have ever consumed it !
>>
>> Is this a known issue in the client ? Can someone please help me ?
>>
>> Rabbitmq server version : 2.7.1
>> Rabbitmq client version : 0.9.1 version of the AMQP protocol
>> Erlang: R15B
>>
>> Thanks !
>>
>>
> I would say a lot depends on what your "node A" code is doing in the
> handling of the nodedown info message. Are you using any State in your
> gen_server? If yes, could that be impacting your RabbitMQ message handling
> in any way? For example, leading to not ack'ing a msg?
>
> Robby
>
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20120312/6ca68312/attachment.htm>