Hi,<div><br></div><div>I'm having trouble getting simple examples of basic_publish to work due to the write buffer being exceeded. If I use the demo_send code from <a href="http://pika.github.com/examples.html">here</a>, I only manage to send 5 messages before getting write buffer exceeded problems. Here's my output:</div>
<div><br></div><div><div>[INFO 2012-05-27 20:30:16,863 #5451] Connecting fd 3 to <a href="http://127.0.0.1:5672">127.0.0.1:5672</a></div><div>[INFO 2012-05-27 20:30:17,869 #5451] demo_send: Connected to RabbitMQ</div>
<div>[INFO 2012-05-27 20:30:17,872 #5451] demo_send: Received our Channel</div><div>[INFO 2012-05-27 20:30:17,882 #5451] demo_send: Queue Declared</div><div>[INFO 2012-05-27 20:30:17,883 #5451] Sending: Hello World #0: 1338147017.88308692</div>
<div>[INFO 2012-05-27 20:30:17,883 #5451] Sending: Hello World #1: 1338147017.88367391</div><div>[INFO 2012-05-27 20:30:17,884 #5451] Sending: Hello World #2: 1338147017.88425899</div><div>[INFO 2012-05-27 20:30:17,884 #5451] Sending: Hello World #3: 1338147017.88472700</div>
<div>[INFO 2012-05-27 20:30:17,885 #5451] Sending: Hello World #4: 1338147017.88527107</div><div>/..snip../pika/connection.py:766: UserWarning: Pika: Write buffer exceeded warning threshold at 413 bytes and an estimated 10 frames behind</div>
<div> warn(message % (self.outbound_buffer.size, est_frames_behind))</div><div>/..snip../pika/connection.py:766: UserWarning: Pika: Write buffer exceeded warning threshold at 447 bytes and an estimated 11 frames behind</div>
<div> warn(message % (self.outbound_buffer.size, est_frames_behind))</div><div>/..snip../pika/connection.py:766: UserWarning: Pika: Write buffer exceeded warning threshold at 490 bytes and an estimated 12 frames behind</div>
<div> warn(message % (self.outbound_buffer.size, est_frames_behind))</div><div>[INFO 2012-05-27 20:30:17,887 #5451] Sending: Hello World #5: 1338147017.88733912</div><div>/..snip../pika/connection.py:766: UserWarning: Pika: Write buffer exceeded warning threshold at 511 bytes and an estimated 13 frames behind</div>
<div> warn(message % (self.outbound_buffer.size, est_frames_behind))</div><div>/..snip../pika/connection.py:766: UserWarning: Pika: Write buffer exceeded warning threshold at 545 bytes and an estimated 14 frames behind</div>
<div> warn(message % (self.outbound_buffer.size, est_frames_behind))</div><div>/..snip../pika/connection.py:766: UserWarning: Pika: Write buffer exceeded warning threshold at 588 bytes and an estimated 15 frames behind</div>
<div> warn(message % (self.outbound_buffer.size, est_frames_behind))</div></div><div><br></div><div>etc etc</div><div><br></div><div>On the other hand, everything works fine with pika twisted and the msgs do end up on RabbitMQ with pika twisted, so it doesn't seem to be a restriction to do with RabbitMQ per se.</div>
<div><br></div><div>I've created <a href="https://gist.github.com/2815757">gists</a> for the pika native code which doesn't work and the pika twisted code that does work.</div><div><br></div><div>If anyone could help, I would greatly appreciate it.</div>
<div><br></div><div>James</div>