<div>
It's worth noting that I do not consider the github master branch stable. If you're looking for the stable branch, make sure you're using 0.9.5.
</div><div><br></div><div>Gavin</div>
<div></div>
<p style="color: #A0A0A8;">On Wednesday, September 21, 2011 at 5:43 AM, Raphaël De GIUSTI wrote:</p>
<blockquote type="cite" style="border-left-style:solid;border-width:1px;margin-left:0px;padding-left:10px;">
<span><div><div>Hi everyone,<div><br></div><div>When I'm running the demo_receive / demo_send example with pika from the master branch (pre0.9.6 i think), I'm getting a strange behaviour.</div><div><br></div><div>It seems that demo_send sends its 10 messages before demo_receive actually receive everything in one shot. It results in a tcp backpressure problem.</div>
<div><br></div><div>In pika 0.9.5 example, demo_receive consumes a message 1 by 1, as it arrives, and acks it, this is what I expect.</div><div><br></div><div>Here's the output from both scripts (I added a 0.5sec sleep after sending a message to see what's happening) :</div>
<div><br></div><blockquote type="cite"><div><blockquote type="cite"><div>
demo_receive:<br>demo_receive: Connected to RabbitMQ<br>demo_receive: Received our Channel<br>demo_receive: Queue Declared<br>Basic.Deliver text/plain delivery-tag 1: Hello World #0: 1316597081.62437701<br>Basic.Deliver text/plain delivery-tag 2: Hello World #1: 1316597082.62570310<br>
Basic.Deliver text/plain delivery-tag 3: Hello World #2: 1316597083.62713790<br>Basic.Deliver text/plain delivery-tag 4: Hello World #3: 1316597084.62860394<br>Basic.Deliver text/plain delivery-tag 5: Hello World #4: 1316597085.63100100<br>
Basic.Deliver text/plain delivery-tag 6: Hello World #5: 1316597086.63265109<br>Basic.Deliver text/plain delivery-tag 7: Hello World #6: 1316597087.63385701<br>Basic.Deliver text/plain delivery-tag 8: Hello World #7: 1316597088.63560796<br>
Basic.Deliver text/plain delivery-tag 9: Hello World #8: 1316597089.63728094<br>Basic.Deliver text/plain delivery-tag 10: Hello World #9: 1316597090.63895893</div></blockquote><div><br></div><div> </div><blockquote type="cite"><div>
</div><div>
demo_send:<br>INFO:pika:Connecting to <a href="http://127.0.0.1:5672">127.0.0.1:5672</a><br>demo_send: Connected to RabbitMQ<br>demo_send: Received our Channel<br>demo_send: Queue Declared<br>demo_send: Sent Hello World #0: 1316597081.62437701<br>
demo_send: Sent Hello World #1: 1316597082.62570310<br>demo_send: Sent Hello World #2: 1316597083.62713790<br>../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 500 bytes and an estimated 10 frames behind<br>
warn(message % (self.outbound_buffer.size, est_frames_behind))<br>demo_send: Sent Hello World #3: 1316597084.62860394<br>../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 521 bytes and an estimated 11 frames behind<br>
warn(message % (self.outbound_buffer.size, est_frames_behind))<br>../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 582 bytes and an estimated 12 frames behind<br> warn(message % (self.outbound_buffer.size, est_frames_behind))<br>
../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 625 bytes and an estimated 13 frames behind<br> warn(message % (self.outbound_buffer.size, est_frames_behind))<br>demo_send: Sent Hello World #4: 1316597085.63100100<br>
../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 646 bytes and an estimated 14 frames behind<br> warn(message % (self.outbound_buffer.size, est_frames_behind))<br>../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 707 bytes and an estimated 15 frames behind<br>
warn(message % (self.outbound_buffer.size, est_frames_behind))<br>../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 750 bytes and an estimated 16 frames behind<br> warn(message % (self.outbound_buffer.size, est_frames_behind))<br>
demo_send: Sent Hello World #5: 1316597086.63265109<br>../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 771 bytes and an estimated 17 frames behind<br> warn(message % (self.outbound_buffer.size, est_frames_behind))<br>
../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 832 bytes and an estimated 18 frames behind<br> warn(message % (self.outbound_buffer.size, est_frames_behind))<br>../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 875 bytes and an estimated 19 frames behind<br>
warn(message % (self.outbound_buffer.size, est_frames_behind))<br>demo_send: Sent Hello World #6: 1316597087.63385701<br>../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 896 bytes and an estimated 20 frames behind<br>
warn(message % (self.outbound_buffer.size, est_frames_behind))<br>../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 957 bytes and an estimated 21 frames behind<br> warn(message % (self.outbound_buffer.size, est_frames_behind))<br>
../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 1000 bytes and an estimated 22 frames behind<br> warn(message % (self.outbound_buffer.size, est_frames_behind))<br>demo_send: Sent Hello World #7: 1316597088.63560796<br>
../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 1021 bytes and an estimated 23 frames behind<br> warn(message % (self.outbound_buffer.size, est_frames_behind))<br>../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 1082 bytes and an estimated 24 frames behind<br>
warn(message % (self.outbound_buffer.size, est_frames_behind))<br>../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 1125 bytes and an estimated 25 frames behind<br> warn(message % (self.outbound_buffer.size, est_frames_behind))<br>
demo_send: Sent Hello World #8: 1316597089.63728094<br>../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 1146 bytes and an estimated 26 frames behind<br> warn(message % (self.outbound_buffer.size, est_frames_behind))<br>
../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 1207 bytes and an estimated 27 frames behind<br> warn(message % (self.outbound_buffer.size, est_frames_behind))<br>../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 1250 bytes and an estimated 28 frames behind<br>
warn(message % (self.outbound_buffer.size, est_frames_behind))<br>demo_send: Sent Hello World #9: 1316597090.63895893<br>demo_send: Closing<br>INFO:pika:Closing connection: 200 - Normal shutdown<br>../pika/connection.py:756: UserWarning: Pika: Write buffer exceeded warning threshold at 1284 bytes and an estimated 29 frames behind<br>
warn(message % (self.outbound_buffer.size, est_frames_behind))<br>INFO:pika:Disconnected from RabbitMQ at <a href="http://127.0.0.1:5672">127.0.0.1:5672</a></div></blockquote></div></blockquote><div><br></div><div>My question is : why all 10 messages arrive in one shot ?</div>
</div><div>_______________________________________________<br>rabbitmq-discuss mailing list<br><a href="mailto:rabbitmq-discuss@lists.rabbitmq.com">rabbitmq-discuss@lists.rabbitmq.com</a><br><a href="https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss">https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a><br></div></div></span>
</blockquote>
<div>
<br>
</div>