<div>mplivelog1 ~: sudo /usr/sbin/rabbitmqctl list_queues -p myqueue name consumers messages messages_ready</div><div><br></div><div>Listing queues ...</div><div>storage<span class="Apple-tab-span" style="white-space:pre"> </span>5<span class="Apple-tab-span" style="white-space:pre"> </span>1<span class="Apple-tab-span" style="white-space:pre"> </span>0</div>
<div>...done.</div><div><br></div><div>I currently have it running again after a restart and that's usually the response I get, usually only 0-5 items in the queue, since it's being processed.</div><div><br></div>
<div>When the error was occurring and I checked the queue, there were effectively *zero* items in the queue according to that command I ran above in the queue. In python I definitely do acknowledge items via:</div><div><br>
</div><div>self.channel.basic_ack(data.delivery_tag)</div><div><br></div><div>where self.channel is�amqp.Connection(host=host, **info).channel()</div><div><br></div><div>Suhail</div><br><div class="gmail_quote">On Thu, Jul 30, 2009 at 12:46 PM, Matthias Radestock <span dir="ltr"><<a href="mailto:matthias@lshift.net">matthias@lshift.net</a>></span> wrote:<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex;"><div class="im">Suhail Doshi wrote:<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">
Looking in my logs shows a large gap in time, in bold is where it is:<br>
<br>
=INFO REPORT==== 30-Jul-2009::17:26:56 ===<br>
� �alarm_handler: {set,{system_memory_high_watermark,[]}}<br>
</blockquote>
<br></div>
This indicates that rabbit got close to running out of memory and told all connected clients to stop sending any more messages. Hence the "Discarding ..." message you were seeing in the erlang client. Your consumers should continue to receive messages, albeit slowly if rabbit is swapping.<br>
<br>
Perhaps your consumers are not acknowledging received messages, causing them to keep piling up at the server?<br>
<br>
I recommend checking the queue lengths/sizes with 'rabbitmqctl list_queues'.<br>
<br>
<br>
Regards,<br><font color="#888888">
<br>
Matthias.<br>
</font></blockquote></div><br><br clear="all"><br>-- <br><a href="http://mixpanel.com">http://mixpanel.com</a><br>Blog: <a href="http://blog.mixpanel.com">http://blog.mixpanel.com</a><br>