<div>
The warnings are just warnings, letting you know that the writes to rabbitMQ are not happening as quickly as you'd like them to do. Are you saying they are not actually getting into RabbitMQ?
</div>
<div></div>
<p style="color: #A0A0A8;">On Sunday, May 27, 2012 at 4:27 PM, James Dear wrote:</p>
<blockquote type="cite" style="border-left-style:solid;border-width:1px;margin-left:0px;padding-left:10px;">
<span><div><div>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>
</div><div><div>_______________________________________________</div><div>rabbitmq-discuss mailing list</div><div><a href="mailto:rabbitmq-discuss@lists.rabbitmq.com">rabbitmq-discuss@lists.rabbitmq.com</a></div><div><a href="https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss">https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a></div></div></div></span>
</blockquote>
<div>
<br>
</div>