[rabbitmq-discuss] Handle Stale Connections on Clients

[Jerry Kuch]

Hi, Monish:

If you're using the naked Java client, you'll have to implement your own
reconnection logic.  If you're using Spring AMQP there's some helper code
that wraps your connections with some retry logic for you.

Best regards,
Jerry

On Tue, Jul 10, 2012 at 9:47 AM, cogitate <monish.unni at gmail.com> wrote:

> Hi Mathias et al:
>
> Given:
> -- java rabbitmq client 2.8.2
> -- rabbitmq broker 2.8.2
> -- wrote an amqp client library (java) that has the following semantics:
> [1] setting up connection properties
>  [1.1] username, password (authentication)
>  [1.2] host, port ( endpoint )
>  [1.3] # of threads(concurrent users), # of connections(conn.), conn.
> timeout, receive timeout
>  * # of usable clients effectively = threads x connections
>
> [2] A manager sets up a pool for fair-sharing of resources per thread.
>  [2.1] sets up a connection pool
>  [2.2] sets up request/reply channels
>  [2.3] sets up re-usable reply-queues
>
> [3] A client class derived from the manager
>  [3.1] this pre-configured (with properties in [2])
>  [3.2] specify exchange(context), routing-key(service), payload(a message)
>
>
> when a broker is shutdown and restarted, the stack i get is :
> [ERROR: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:190)
>         at com.rabbitmq.client.impl.AMQChannel.rpc(AMQChannel.java:223)
>         at
> com.rabbitmq.client.impl.AMQChannel.privateRpc(AMQChannel.java:209)
>         at
> com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:118)
>         at
> com.rabbitmq.client.impl.ChannelN.exchangeDeclarePassive(ChannelN.java:660)
>         at
> com.rabbitmq.client.impl.ChannelN.exchangeDeclarePassive(ChannelN.java:61)
>         at com.xx.s2.amqp.AmqpClient.doSend(AmqpClient.java:187)
>         at com.xx.s2.amqp.AmqpClient.callService(AmqpClient.java:80)
>         at
>
> com.xx.s2.amqp.StaleConnectionTest.callLoopTest(StaleConnectionTest.java:132)
>         at
> com.xx.s2.amqp.StaleConnectionTest.loopTest(StaleConnectionTest.java:86)
>
> at this point, i have to shutdown the client using the library and restart
> it. is there a way to handle this exception and re-establish the
> connection?
> any utilities that will allow me to do this "automatically"?
>
> thanks and regards,
> -monish
>
> --
> View this message in context:
> http://rabbitmq.1065348.n5.nabble.com/Handle-Stale-Connections-on-Clients-tp20687.html
> Sent from the RabbitMQ mailing list archive at Nabble.com.
> _______________________________________________
> 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/20120710/8e2059be/attachment.htm>