[rabbitmq-discuss] pika basic_ack dying

Fri Sep 23 00:38:17 BST 2011

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