<div dir="ltr"><div class="gmail_extra"><br><div class="gmail_quote">2013/6/7 tluck <span dir="ltr">&lt;<a href="mailto:tilak.chauhan@ymail.com" target="_blank">tilak.chauhan@ymail.com</a>&gt;</span><br><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">

<div id=":80v" style="overflow:hidden">while ($msg = $channel-&gt;basic_get($queue)) {<br>
    consumerMessage($msg, $connection, $channel);<br>
}</div></blockquote></div><br>I suspect this code uses automatic acknowledgement mode. In other words, RabbitMQ considers the message acknowledged as soon as</div><div class="gmail_extra">it sends it out.<br><br clear="all">

<div>If you want to use explicit acks (it only makes sense if you want messages to be requeued</div><div>in case your consumer crashes), you need to specify it as an extra argument to basic.get.</div><div><br></div><div>
Alternatively you can stop using explicit acks. In that case a consumer that fails before the messages is</div>
<div>processed will cause the message to be lost.</div>-- <br>MK<br><br><a href="http://github.com/michaelklishin" target="_blank">http://github.com/michaelklishin</a><br><a href="http://twitter.com/michaelklishin" target="_blank">http://twitter.com/michaelklishin</a><br>


</div></div>