[rabbitmq-discuss] Pika write buffer problem

[James Dear]

Hi,

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
here<http://pika.github.com/examples.html>,
I only manage to send 5 messages before getting write buffer exceeded
problems. Here's my output:

[INFO     2012-05-27 20:30:16,863  #5451] Connecting fd 3 to 127.0.0.1:5672
[INFO     2012-05-27 20:30:17,869  #5451] demo_send: Connected to RabbitMQ
[INFO     2012-05-27 20:30:17,872  #5451] demo_send: Received our Channel
[INFO     2012-05-27 20:30:17,882  #5451] demo_send: Queue Declared
[INFO     2012-05-27 20:30:17,883  #5451] Sending: Hello World #0:
1338147017.88308692
[INFO     2012-05-27 20:30:17,883  #5451] Sending: Hello World #1:
1338147017.88367391
[INFO     2012-05-27 20:30:17,884  #5451] Sending: Hello World #2:
1338147017.88425899
[INFO     2012-05-27 20:30:17,884  #5451] Sending: Hello World #3:
1338147017.88472700
[INFO     2012-05-27 20:30:17,885  #5451] Sending: Hello World #4:
1338147017.88527107
/..snip../pika/connection.py:766: UserWarning: Pika: Write buffer exceeded
warning threshold at 413 bytes and an estimated 10 frames behind
  warn(message % (self.outbound_buffer.size, est_frames_behind))
/..snip../pika/connection.py:766: UserWarning: Pika: Write buffer exceeded
warning threshold at 447 bytes and an estimated 11 frames behind
  warn(message % (self.outbound_buffer.size, est_frames_behind))
/..snip../pika/connection.py:766: UserWarning: Pika: Write buffer exceeded
warning threshold at 490 bytes and an estimated 12 frames behind
  warn(message % (self.outbound_buffer.size, est_frames_behind))
[INFO     2012-05-27 20:30:17,887  #5451] Sending: Hello World #5:
1338147017.88733912
/..snip../pika/connection.py:766: UserWarning: Pika: Write buffer exceeded
warning threshold at 511 bytes and an estimated 13 frames behind
  warn(message % (self.outbound_buffer.size, est_frames_behind))
/..snip../pika/connection.py:766: UserWarning: Pika: Write buffer exceeded
warning threshold at 545 bytes and an estimated 14 frames behind
  warn(message % (self.outbound_buffer.size, est_frames_behind))
/..snip../pika/connection.py:766: UserWarning: Pika: Write buffer exceeded
warning threshold at 588 bytes and an estimated 15 frames behind
  warn(message % (self.outbound_buffer.size, est_frames_behind))

etc etc

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.

I've created gists <https://gist.github.com/2815757> for the pika native
code which doesn't work and the pika twisted code that does work.

If anyone could help, I would greatly appreciate it.

James
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20120527/ca5a7c9f/attachment.htm>