Hi,<div><br></div><div>Thanks for your response and sorry for using google groups.</div><div><br></div><div>We just have found why we don't get messages anymore from the broker.�</div><div>Your explanation corresponds exactly to our problem : when Hbase connection fails, it generates an exception, and in this case, we don't 'ack' nor 'nack/reject' the message.�</div>
<div><br></div><div>Now, we nack the message when something wrong occurs and so we get the next messages from the queue.</div><div><br></div><div>Thanks again,</div><div>Nicolas</div><div><br><br><div class="gmail_quote">
2012/10/19 Tim Watson <span dir="ltr"><<a href="mailto:tim@rabbitmq.com" target="_blank">tim@rabbitmq.com</a>></span><br><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">
Hi<br>
<br>
Please do not use the google group, as we do not own or subscribe to it. Thanks!<br>
<br>
In terms of your question, please see my comments inline (below).<br>
<br>
On 10/18/2012 04:50 PM, Nicolas Bosansky wrote:<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">
Hello,<br>
We have a rabbitMQ consumer that takes messages from a queue and write them in a HBase store.<br>
When HBase connection fails, the consumer get an exception and messages are not acknowledged, that's ok.<br>
After a few minutes, the consumer doesn't get messages anymore, even after restarting Hbase.<br>
<br>
</blockquote>
<br>
Firstly, I don't really understand what you're describing here. What does the HBase connection failure have to do with the rabbitmq consumer? Are you saying that the HBase connection failure causes an unhandled exception on the thread which the consumer is running in? What does this have to do with acks - are you saying that your client code does not ack messages which arrive that cannot be written to HBase? That's fine, but you ought to nack/reject them unless you're hanging on to them deliberately in order to deal with them later on. Perhaps this is what is causing the problem?<br>
<br>
"If a consumer dies without sending an acknowledgement the AMQP broker will redeliver it to another consumer or, if none are available at the time, the broker will wait until at least one consumer is registered for the same queue before attempting redelivery." - <a href="http://www.rabbitmq.com/tutorials/amqp-concepts.html" target="_blank">http://www.rabbitmq.com/<u></u>tutorials/amqp-concepts.html</a><br>
<br>
So if you do not ack the messages you've already received *nor* nack/reject them, then you're not going to get any more messages until you do? Am I missing something here, or are you just not instructing the broker that you're ready to continue consuming from the queue (by dealing with the messages it has already sent you which need to be ack'ed or rejected)?<br>
<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">
When debugging rabbitMQ client, we have noticed, that it is blocked on the following line: SocketInputStream:129 ( Java build 1.6.0_33-b03)<br>
The Frame class is waiting for messages, but the used socket doesn't receive any data anymore.<br>
We also notice, that there is no timeout on this socket.<br>
<br>
</blockquote>
<br>
There isn't meant to be a timeout when reading frames.<br>
</blockquote></div><br></div>