[rabbitmq-discuss] pika basic_ack dying

Fri Sep 23 02:28:27 BST 2011

You're handling things with multiprocessing, does each process have its own connection?

How are you handling communication across the processes (or are you?) 

On Thursday, September 22, 2011 at 7:38 PM, Stephen Young wrote:

> I tried posting this before and hit an error (i think) so sorry if it
> is a repost...
> 
> I'm using rabbitmq with a single exchange and multiple queues, and
> many servers each monitoring all queues.
> 
> When i start the servers monitoring clean (empty) queues, basic_ack
> works fine and they process anything new that comes in. Any queues
> with pre-existing data won't accept a basic_ack (or the channel
> doesn't send it, I'm not sure how to debug this..?) and hangs after
> processing the first item. I'm using a qos of 1 for testing purposes.
> 
> I'm handling the queues with multiprocessing, so I pass the
> _onComplete callback to resolve the queue...
> 
> ========================================================
> def _onComplete():
>  self.channel.basic_ack(delivery_tag=method.delivery_tag)
>  print "Sent delivery tag %s via %s" %
> (method.delivery_tag,channel)
> 
> kwargs = {
>  'data': message['data'],
>  'oncomplete': _onComplete,
> }
> 
> p = Process(target=self._registry(message['key']),
> args=[],kwargs=kwargs)
> p.start()
> ========================================================
> 
> Not sure if the problem is clear, hopefully someone can shed some
> light on why it happens though
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com (mailto:rabbitmq-discuss at lists.rabbitmq.com)
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20110922/19b527b9/attachment.htm>