[rabbitmq-discuss] channel.flow in pyampqlib (was: Re: Erlang has closed?)

Wed Sep 29 10:09:59 BST 2010

On Tue, Sep 28, 2010 at 9:19 PM, Matthias Radestock
<matthias at rabbitmq.com> wrote:
> As others have pointed out, pika may be an option. HOWEVER, since the 2.0.0
> release rabbit is using tcp backpressure to throttle producers, which should
> work with *any* client regardless of whether they support channel.flow. See
> the docs at http://www.rabbitmq.com/extensions.html#memsup

Java client uses blocking IO. It would hang on writing to server that
throttles producers. Dealing with it means starting separate thread by
hands for every connection just to use BlockingQueue.offer with
timeout.

Do you have any plans to switch java client to non-blocking IO (NIO)
and introduce timeouts in content sending methods?

Regards,
Anton Lebedevich.