[rabbitmq-discuss] Fwd: chan.flow and vm_memory_high_watermark
scott at beamdog.com
Thu Jun 10 16:30:41 BST 2010
You would consume with acks turned on.
Then once you ack a message, rabbitmq will send you another.
You can use all the extra parameters to rabbitmqctl list_queues to see
how many messages are sent but not acknowledged, etc.
2010/6/10 Nicolás César <nico at nicocesar.com>:
> Ops! this mail went to Simon only, I'm posting here if any has an extra tip
> for me. Thanks
> Nico César
> ---------- Mensaje reenviado ----------
> De: Nicolás César <nico at nicocesar.com>
> Fecha: 10 de junio de 2010 11:18
> Asunto: Re: [rabbitmq-discuss] chan.flow and vm_memory_high_watermark
> Para: Simon MacMullen <simon at rabbitmq.com>
> El 10 de junio de 2010 10:02, Nicolás César <nico at nicocesar.com> escribió:
>>>> is there any way to tell the broker to consume at a fixed rate with
>>>> chan.basic_consume(...callback = f)?
>>> Yes, basic.qos. This not-very-well-named method lets you specify how many
>>> unacked messages the server will send to you at any time. So set qos to a
>>> low value, then use basic_consume with a sleep before acking.
>> Nice to hear a yes here!! I'll be changing my code to get this working!
> I'm sorry but I just don't get the use of basic_qos and fixed rate consuming
> toghether!. My investigation so far leads that the parameters I have for a
> QoS are:
> basic_qos(prefetch_size, prefetch_count, a_global)
> soppose that I use
> basic_qos(prefetch_size=0, prefetch_count=1, a_global=False)
> How can I limit "consume 1 message every 2 seconds" (that's my fixed rete)
> using chan.basic_consume(...callback = f)?
> If you could give me any help here would be very appreciated.
> Nico Cesar
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
More information about the rabbitmq-discuss