analyse how to handle network failures for RabbitMQ.

[shubham7saxena]

Applications stop consuming messages in case RabbitMQ restarts or there are connectivity issues.

[ERROR] 2019-04-20 16:05:11,345 [AMQP Connection 127.0.0.1:5672] com.rabbitmq.client.impl.ForgivingExceptionHandler:log: Caught an exception when recovering topology Caught an exception while recovering binding between booking_dss_transport_instant_exchange and booking_dss_transport_instant_queue: channel is already closed due to clean channel shutdown; protocol method: #method<channel.close>(reply-code=200, reply-text=OK, class-id=0, method-id=0)
com.rabbitmq.client.TopologyRecoveryException: Caught an exception while recovering binding between booking_dss_transport_instant_exchange and booking_dss_transport_instant_queue: channel is already closed due to clean channel shutdown; protocol method: #method<channel.close>(reply-code=200, reply-text=OK, class-id=0, method-id=0)
    at com.rabbitmq.client.impl.recovery.AutorecoveringConnection.recoverBindings(AutorecoveringConnection.java:698) [amqp-client-5.2.0.jar:5.2.0]
    at com.rabbitmq.client.impl.recovery.AutorecoveringConnection.recoverEntities(AutorecoveringConnection.java:637) [amqp-client-5.2.0.jar:5.2.0]
    at com.rabbitmq.client.impl.recovery.AutorecoveringConnection.beginAutomaticRecovery(AutorecoveringConnection.java:559) [amqp-client-5.2.0.jar:5.2.0]
    at com.rabbitmq.client.impl.recovery.AutorecoveringConnection.access$000(AutorecoveringConnection.java:58) [amqp-client-5.2.0.jar:5.2.0]
    at com.rabbitmq.client.impl.recovery.AutorecoveringConnection$3.recoveryCanBegin(AutorecoveringConnection.java:488) [amqp-client-5.2.0.jar:5.2.0]
    at com.rabbitmq.client.impl.AMQConnection.notifyRecoveryCanBeginListeners(AMQConnection.java:748) [amqp-client-5.2.0.jar:5.2.0]
    at com.rabbitmq.client.impl.AMQConnection.doFinalShutdown(AMQConnection.java:725) [amqp-client-5.2.0.jar:5.2.0]
    at com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:609) [amqp-client-5.2.0.jar:5.2.0]
    at java.lang.Thread.run(Thread.java:748) [?:1.8.0_131]

[shubham7saxena]

#42