[rabbitmq-discuss] pika basic_ack dying

[Gavin M. Roy]

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>