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

[Nicolás César]

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
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20100610/bde1d719/attachment.htm>