RabbitMQ Connection was not recovering

[dilshanfardil]

Hi Team,

We are getting this ERROR when try to publish the message to the RabbitMQ Broker.

[2024-05-14 13:13:25,811] ERROR {org.apache.synapse.message.store.impl.rabbitmq.RabbitMQProducer} - [CdxUpdateQueue-P-56073]. Ignored MessageId: urn:uuid:81ec84bf-5868-4170-8dfa-af29e6137400. Could not store message to store [CdxUpdateQueue]. Error:connection is already closed due to connection error; cause: java.net.SocketException: Connection reset com.rabbitmq.client.AlreadyClosedException: connection is already closed due to connection error; cause: java.net.SocketException: Connection reset
	at com.rabbitmq.client.impl.AMQChannel.ensureIsOpen(AMQChannel.java:281)
	at com.rabbitmq.client.impl.AMQChannel.transmit(AMQChannel.java:469)
	at com.rabbitmq.client.impl.ChannelN.lambda$basicPublish$1(ChannelN.java:729)
	at com.rabbitmq.client.observation.NoOpObservationCollector.publish(NoOpObservationCollector.java:32)
	at com.rabbitmq.client.impl.ChannelN.basicPublish(ChannelN.java:731)
	at com.rabbitmq.client.impl.ChannelN.basicPublish(ChannelN.java:703)
	at com.rabbitmq.client.impl.ChannelN.basicPublish(ChannelN.java:693)
	at com.rabbitmq.client.impl.recovery.AutorecoveringChannel.basicPublish(AutorecoveringChannel.java:207)
	at org.apache.synapse.message.store.impl.rabbitmq.RabbitMQProducer.publishMessage(RabbitMQProducer.java:177)
	at org.apache.synapse.message.store.impl.rabbitmq.RabbitMQProducer.storeMessage(RabbitMQProducer.java:94)
	at org.apache.synapse.mediators.store.MessageStoreMediator.mediate(MessageStoreMediator.java:126)
	at org.apache.synapse.mediators.AbstractListMediator.mediate(AbstractListMediator.java:110)
	at org.apache.synapse.mediators.AbstractListMediator.mediate(AbstractListMediator.java:72)
	at org.apache.synapse.mediators.base.SequenceMediator.mediate(SequenceMediator.java:158)
	at org.apache.synapse.mediators.MediatorWorker.run(MediatorWorker.java:87)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:829)

As per this finding the channel and the connection as not getting null if there was an Runtime exception was thrown.

[1] https://github.com/wso2/wso2-synapse/blob/98a8a8f595a840f6d8684368987478140db4dc0f/modules/core/src/main/java/org/apache/synapse/message/store/impl/rabbitmq/RabbitMQProducer.java#L128

Thank You
DilshanF