<div>You're handling things with multiprocessing, does each process have its own connection?</div><div><br></div><div>How are you handling communication across the processes (or are you?)</div>
                 
                  
                <p style="color: #A0A0A8;">On Thursday, September 22, 2011 at 7:38 PM, Stephen Young wrote:</p><blockquote type="cite"><div>
                    <span><div><div>I tried posting this before and hit an error (i think) so sorry if it<br>is a repost...<br><br>I'm using rabbitmq with a single exchange and multiple queues, and<br>many servers each monitoring all queues.<br><br>When i start the servers monitoring clean (empty) queues, basic_ack<br>works fine and they process anything new that comes in. Any queues<br>with pre-existing data won't accept a basic_ack (or the channel<br>doesn't send it, I'm not sure how to debug this..?) and hangs after<br>processing the first item. I'm using a qos of 1 for testing purposes.<br><br>I'm handling the queues with multiprocessing, so I pass the<br>_onComplete callback to resolve the queue...<br><br>========================================================<br>def _onComplete():<br>    self.channel.basic_ack(delivery_tag=method.delivery_tag)<br>    print "Sent delivery tag %s via %s" %<br>(method.delivery_tag,channel)<br><br>kwargs = {<br>    'data': message['data'],<br>    'oncomplete': _onComplete,<br>}<br><br>p = Process(target=self._registry(message['key']),<br>args=[],kwargs=kwargs)<br>p.start()<br>========================================================<br><br>Not sure if the problem is clear, hopefully someone can shed some<br>light on why it happens though<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">https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a><br></div></div></span>
                  
                  
                  
                  
                </div></blockquote><div>
                    <br>
                </div>