[rabbitmq-discuss] [rabbitmq-erlang-client] Missing 1 queue message after nodedown message from another node.
virolord at gmail.com
Mon Mar 12 14:17:47 GMT 2012
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
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
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:
>> 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?
-------------- next part --------------
An HTML attachment was scrubbed...
More information about the rabbitmq-discuss