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 class="webkit-indent-blockquote" style="margin: 0 0 0 40px; border: none; padding: 0px;"><blockquote class="gmail_quote" style="margin-top: 0px; margin-right: 0px; margin-bottom: 0px; margin-left: 0.8ex; border-left-width: 1px; border-left-color: rgb(204, 204, 204); border-left-style: solid; padding-left: 1ex; ">
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</blockquote><div><br></div><div>�</div><blockquote class="gmail_quote" style="margin-top: 0px; margin-right: 0px; margin-bottom: 0px; margin-left: 0.8ex; border-left-width: 1px; border-left-color: rgb(204, 204, 204); border-left-style: solid; padding-left: 1ex; ">
�</blockquote><blockquote class="gmail_quote" style="margin-top: 0px; margin-right: 0px; margin-bottom: 0px; margin-left: 0.8ex; border-left-width: 1px; border-left-color: rgb(204, 204, 204); border-left-style: solid; padding-left: 1ex; ">
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></blockquote></blockquote><div><br></div><div>My question is : �why all 10 messages arrive in one shot ?</div>