[rabbitmq-discuss] How can I avoid write buffer warnings for non persistant messaging?

c00kiemonster ake.kullenberg at gmail.com
Wed Sep 5 01:43:50 BST 2012


I am using pika to communicate between server instances on a linux
server and client instances on windows workstations. I had some issues
with SelectConnection that disappeared when I switched to
BlockingConnection but now I only have one issue left, write buffer
warnings.

I don't need messages to be persistant, and I don't need exchanges and
queues to survive a restart of the rabbitmq server. So after reading
up on AMQP I changed all exchanges (only using topic exchanges) and
queues to be non durable and with auto_delete set to True. All
messages are sent as non persistant and they are consumed with no_ack
set to True. I have confirmed the exchange and queue settings are
correct with rabbitmqctl and all messages received are verified to
have deliver_mode set to 1. So far so good.

But when I start the server instance before the client, ie, the server
instance sends out messages with routing keys that there are no
receivers for, I get write buffer warnings like this one:

2012-09-04 09:05:29,402 - server.STDERR - ERROR - /usr/local/lib/
python2.7/dist-packages/pika-0.9.5-py2.7.egg/pika/connection.py:650:
UserWarning: Pika: Write buffer exceeded warning threshold at 1595
bytes and an estimated 10 frames behind

Am I misunderstanding something here? Because my messages are not
persistant and the exchanges and queues are non durable I would expect
rabbitmq to simply discard messages sent with routing keys that are
without any receiver.

Could someone please explain / help out?

Thanks much!


More information about the rabbitmq-discuss mailing list