[rabbitmq-discuss] Fwd: chan.flow and vm_memory_high_watermark

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.

Scott

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!
>> Thanks!
>
> Simon,
>
> 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.
>
> Greetings,
>
> Nico Cesar
>
>
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>