[rabbitmq-discuss] Pika write buffer problem

[James Dear]

Yeah I could understand if it was happening after the thousandth, or maybe
even the hundredth message, but tenth? Why would it slow down after just
ten messages?

The messages are indeed getting to rabbitmq, but very slowly.

If I use pika twisted I don't get this problem at all.
On May 27, 2012 10:01 PM, "Gavin M. Roy" <gmr at myyearbook.com> wrote:

>  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?
>
> On Sunday, May 27, 2012 at 4:27 PM, James Dear wrote:
>
> 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
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20120602/1f93f67a/attachment.htm>