[rabbitmq-discuss] channel.flow in pyampqlib

[Matthias Radestock]

Anton,

On 29/09/10 10:09, mabrek wrote:
> Java client uses blocking IO. It would hang on writing to server that
> throttles producers.
>
> Do you have any plans to switch java client to non-blocking IO (NIO)
> and introduce timeouts in content sending methods?

you could try setting a timeout on the socket with setSoTimeout. One 
place to do that is by overriding 
http://www.rabbitmq.com/releases/rabbitmq-java-client/v2.1.0/rabbitmq-java-client-javadoc-2.1.0/com/rabbitmq/client/ConnectionFactory.html#configureSocket(java.net.Socket)

I haven't tried this myself, and it may not work, or indeed break other 
parts of the client API. But it's worth a shot.


Matthias.