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>>