Pika + RabbitMQ: establecer basic_qos para prefetch = 1 todavía parece consumir todos los mensajes en la cola

Question

Tengo un cliente python worker que genera 10 trabajadores que se enganchan en una cola RabbitMQ. Un poco como esto:

#!/usr/bin/python 
worker_count=10 

def mqworker(queue, configurer): 
    connection = pika.BlockingConnection(pika.ConnectionParameters(host='mqhost')) 
    channel = connection.channel() 
    channel.queue_declare(queue=qname, durable=True) 
    channel.basic_consume(callback,queue=qname,no_ack=False) 
    channel.basic_qos(prefetch_count=1) 
    channel.start_consuming() 


def callback(ch, method, properties, body): 
    doSomeWork(); 
    ch.basic_ack(delivery_tag = method.delivery_tag) 

if __name__ == '__main__': 
    for i in range(worker_count): 
     worker = multiprocessing.Process(target=mqworker) 
     worker.start() 

El problema que tengo es que a pesar de la configuración basic_qos en el canal, el primer trabajador a iniciar acepta todos los mensajes de la cola, mientras que los otros se sientan allí inactivo. Puedo ver esto en la interfaz de rabbitmq, que incluso cuando establezco worker_count en 1 y vuelco 50 mensajes en la cola, los 50 entran en el depósito "no reconocido", mientras que yo esperaría que 1 fuera no reconocido y los otros 49 en estar listo.

¿Por qué no funciona?

Answer 1

Parece que he resuelto esto moviéndome a donde se llama basic_qos.

Colocarlo justo después de channel = connection.channel() parece alterar el comportamiento de lo que esperaba.