Handle all malformed channel and connection closing errors

wso2 · May 28, 2024 · 23608ab · 23608ab
1 parent 98a8a8f
commit 23608ab
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...s/core/src/main/java/org/apache/synapse/message/store/impl/rabbitmq/RabbitMQProducer.java b/...s/core/src/main/java/org/apache/synapse/message/store/impl/rabbitmq/RabbitMQProducer.java
@@ -112,17 +112,17 @@ public boolean storeMessage(MessageContext synCtx) {
             if (channel != null) {
                 try {
                     channel.close();
-                } catch (IOException | TimeoutException exception) {
+                } catch (Exception channelCloseException) {
                     log.error("Error occurred while closing the malformed channel Error: " +
-                            exception.getLocalizedMessage());
+                            channelCloseException.getLocalizedMessage());
                 }
             }
             if (connection != null) {
                 try {
                     connection.close();
-                } catch (IOException ioException) {
+                } catch (Exception connectionCloseException) {
                     log.error("Error occurred while closing the malformed connection Error: " +
-                            ioException.getLocalizedMessage());
+                            connectionCloseException.getLocalizedMessage());
                 }
             }
             channel = null;