Hi Robert !<div><br></div><div>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.</div>
<div><br></div><div>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..</div>
<div><br></div><div>Thanks, </div><div>Abhinav</div><div><br><div class="gmail_quote">On Mon, Mar 12, 2012 at 2:07 PM, Robert Raschke <span dir="ltr"><<a href="mailto:rtrlists@googlemail.com">rtrlists@googlemail.com</a>></span> wrote:<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex"><div class="HOEnZb"><div class="h5"><br><div class="gmail_quote">On Fri, Mar 9, 2012 at 6:58 PM, Abhinav Jha <span dir="ltr"><<a href="mailto:virolord@gmail.com" target="_blank">virolord@gmail.com</a>></span> wrote:<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">
Hi, <div><br></div><div>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 ).</div><div><br></div><div>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. </div>
<div><br></div><div>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 !</div>
<div><br></div><div>Is this a known issue in the client ? Can someone please help me ? </div><div><br></div><div>Rabbitmq server version : 2.7.1</div><div>Rabbitmq client version : 0.9.1 version of the AMQP protocol</div>
<div>Erlang: R15B </div><div><br></div><div>Thanks !</div>
<br></blockquote></div><br></div></div>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?<br>
<br>
Robby<br><br>
</blockquote></div><br></div>