Ops! this mail went to Simon only, I'm posting here if any has an extra tip for me. Thanks<br clear="all"><br>Nico César<br>
<br><br><div class="gmail_quote">---------- Mensaje reenviado ----------<br>De: <b class="gmail_sendername">Nicolás César</b> <span dir="ltr"><<a href="mailto:nico@nicocesar.com">nico@nicocesar.com</a>></span><br>Fecha: 10 de junio de 2010 11:18<br>
Asunto: Re: [rabbitmq-discuss] chan.flow and vm_memory_high_watermark<br>Para: Simon MacMullen <<a href="mailto:simon@rabbitmq.com">simon@rabbitmq.com</a>><br><br><br><div class="gmail_quote">El 10 de junio de 2010 10:02, Nicolás César <span dir="ltr"><<a href="mailto:nico@nicocesar.com" target="_blank">nico@nicocesar.com</a>></span> escribió:<br>
<blockquote class="gmail_quote" style="border-left: 1px solid rgb(204, 204, 204); margin: 0pt 0pt 0pt 0.8ex; padding-left: 1ex;">
(..)<div class="im"><br><div class="gmail_quote"><div><blockquote class="gmail_quote" style="border-left: 1px solid rgb(204, 204, 204); margin: 0pt 0pt 0pt 0.8ex; padding-left: 1ex;"><div><blockquote class="gmail_quote" style="border-left: 1px solid rgb(204, 204, 204); margin: 0pt 0pt 0pt 0.8ex; padding-left: 1ex;">
is there any way to tell the broker to consume at a fixed rate with<br>
chan.basic_consume(...callback = f)?<br>
</blockquote>
<br></div>
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.<br></blockquote>
</div><div><br>Nice to hear a yes here!! I'll be changing my code to get this working! Thanks! <br></div></div></div></blockquote></div><br>Simon, <br><br>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:<br>
<pre><span><span>basic_qos</span>(prefetch_size, prefetch_count, a_global)<br></span></pre>soppose that I use <br><br><pre><span><span>basic_qos</span>(prefetch_size=0, prefetch_count=1, a_global=False)</span></pre>
<br>How can I limit "consume 1 message every 2 seconds" (that's my fixed rete) using chan.basic_consume(...callback = f)?<br><br>If you could give me any help here would be very appreciated.<br><br>Greetings,<br>
<br>Nico Cesar<br>
</div><br>