Are you issuing a basic.recover?<div><br></div><div><a href="http://www.rabbitmq.com/amqp-0-9-1-quickref.html#basic.recover">http://www.rabbitmq.com/amqp-0-9-1-quickref.html#basic.recover</a><br><br><div class="gmail_quote">
On Thu, Sep 29, 2011 at 3:05 PM, Aaron Voelker <span dir="ltr"><<a href="mailto:aaron@contextlogic.com">aaron@contextlogic.com</a>></span> wrote:<br><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex;">
I am using rabbitmq server 2.6.1, pika 0.9.5, python 2.6.6 and ubuntu<br>
10.10.<br>
<br>
I have multiple queues for multiple consumer (many to many), each with<br>
a prefetch count of 5.<br>
<br>
I've encountered a rare issue whereby a consumer that is currently<br>
processing some messages (and has yet to ack them) suddenly<br>
terminates. Obviously, this part is my problem (it's often the OS<br>
killing the process due to consuming too much memory).<br>
<br>
However, the effects are less than ideal. The messages remain unack'd<br>
in the queue (verified by the Management Plugin), even though the<br>
connection is no longer there (unless for some reason the OS is<br>
deciding to keep the socket open?). This leads to that work never<br>
being re-delegated.<br>
<br>
Moreover, a few times when I've restarted the consumer, it's still<br>
unable to consume those messages and starves itself because it thinks<br>
they're still being worked on (and because of the prefetch count of 5<br>
only allowing 5 unack'd messages), even though they are not being<br>
worked on. This usually doesn't happen, but if it does I restart it<br>
again and it finally works.<br>
<br>
Any ideas as to what's happening and if there are any workarounds?<br>
<br>
Thanks,<br>
Aaron<br>
_______________________________________________<br>
rabbitmq-discuss mailing list<br>
<a href="mailto:rabbitmq-discuss@lists.rabbitmq.com">rabbitmq-discuss@lists.rabbitmq.com</a><br>
<a href="https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss" target="_blank">https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a><br>
</blockquote></div><br></div>