[rabbitmq-discuss] Reproducible error for remote client -- was Re: Distributed queue setup

Matthias Radestock matthias at rabbitmq.com
Fri Jul 8 10:30:44 BST 2011


Greg,

On 08/07/11 02:17, Meredith Gregory wrote:
> If we have a client from machine B connect to the RabbitMQ broker on
> machine A and then begin sending messages, the broker closes the
> connection unless we fire up a client to connect to the broker on
> machine A to begin reading the messages. The number of messages
> before closure depends on the size of the message. i have a trace
> below.
> [...]
> scala> net.liftweb.amqp.JSONAMQPSender at 37c1e7d: caught
> com.rabbitmq.client.AlreadyClosedException: clean connection shutdown;
> reason: Attempt to use closed channel
> com.rabbitmq.client.AlreadyClosedException: clean connection shutdown;
> reason: Attempt to use closed channel
> at com.rabbitmq.client.impl.AMQChannel.ensureIsOpen(AMQChannel.java:181)
> at com.rabbitmq.client.impl.AMQChannel.transmit(AMQChannel.java:276)
> at com.rabbitmq.client.impl.ChannelN.basicPublish(ChannelN.java:521)
> at com.rabbitmq.client.impl.ChannelN.basicPublish(ChannelN.java:507)
> at net.liftweb.amqp.AMQPSender.send(AMQPSender.scala:30)

When that happens, look at channel.getCloseReason() to get an 
explanation for why the channel was closed. Alternatively, look at the 
broker logs.


Matthias.


More information about the rabbitmq-discuss mailing list