diff --git a/components/inbound-endpoints/org.wso2.carbon.inbound.endpoint/src/main/java/org/wso2/carbon/inbound/endpoint/protocol/mqtt/MqttConnectionFactory.java b/components/inbound-endpoints/org.wso2.carbon.inbound.endpoint/src/main/java/org/wso2/carbon/inbound/endpoint/protocol/mqtt/MqttConnectionFactory.java
index 74dc3eccbaa..3f519eb4bca 100644
--- a/components/inbound-endpoints/org.wso2.carbon.inbound.endpoint/src/main/java/org/wso2/carbon/inbound/endpoint/protocol/mqtt/MqttConnectionFactory.java
+++ b/components/inbound-endpoints/org.wso2.carbon.inbound.endpoint/src/main/java/org/wso2/carbon/inbound/endpoint/protocol/mqtt/MqttConnectionFactory.java
@@ -356,14 +356,18 @@ protected SSLSocketFactory getSocketFactory(String keyStoreLocation,
 
         char[] keyPassphrase = keyStorePassword.toCharArray();
         KeyStore keyStore = KeyStore.getInstance(keyStoreType);
-        keyStore.load(new FileInputStream(keyStoreLocation), keyPassphrase);
+        try (FileInputStream keyStoreStream = new FileInputStream(keyStoreLocation)) {
+            keyStore.load(keyStoreStream, keyPassphrase);
+        }
 
         KeyManagerFactory keyManagerFactory = KeyManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm());
         keyManagerFactory.init(keyStore, keyPassphrase);
 
         char[] trustPassphrase = trustStorePassword.toCharArray();
         KeyStore trustStore = KeyStore.getInstance(trustStoreType);
-        trustStore.load(new FileInputStream(trustStoreLocation), trustPassphrase);
+        try (FileInputStream trustStoreStream = new FileInputStream(trustStoreLocation)) {
+            trustStore.load(trustStoreStream, trustPassphrase);
+        }
 
         TrustManagerFactory trustManagerFactory = TrustManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm());
         trustManagerFactory.init(trustStore);
diff --git a/components/inbound-endpoints/org.wso2.carbon.inbound.endpoint/src/main/java/org/wso2/carbon/inbound/endpoint/protocol/rabbitmq/RabbitMQConnectionFactory.java b/components/inbound-endpoints/org.wso2.carbon.inbound.endpoint/src/main/java/org/wso2/carbon/inbound/endpoint/protocol/rabbitmq/RabbitMQConnectionFactory.java
index 08863e6f1ef..97fe219f390 100644
--- a/components/inbound-endpoints/org.wso2.carbon.inbound.endpoint/src/main/java/org/wso2/carbon/inbound/endpoint/protocol/rabbitmq/RabbitMQConnectionFactory.java
+++ b/components/inbound-endpoints/org.wso2.carbon.inbound.endpoint/src/main/java/org/wso2/carbon/inbound/endpoint/protocol/rabbitmq/RabbitMQConnectionFactory.java
@@ -178,14 +178,18 @@ private void setSSL(Map<String, String> parameters, boolean sslEnabled) {
                 } else {
                     char[] keyPassphrase = keyStorePassword.toCharArray();
                     KeyStore ks = KeyStore.getInstance(keyStoreType);
-                    ks.load(new FileInputStream(keyStoreLocation), keyPassphrase);
+                    try (FileInputStream keyStoreStream = new FileInputStream(keyStoreLocation)) {
+                        ks.load(keyStoreStream, keyPassphrase);
+                    }
 
                     KeyManagerFactory kmf = KeyManagerFactory.getInstance(KeyManagerFactory.getDefaultAlgorithm());
                     kmf.init(ks, keyPassphrase);
 
                     char[] trustPassphrase = trustStorePassword.toCharArray();
                     KeyStore tks = KeyStore.getInstance(trustStoreType);
-                    tks.load(new FileInputStream(trustStoreLocation), trustPassphrase);
+                    try (FileInputStream trustStoreStream = new FileInputStream(trustStoreLocation)) {
+                        tks.load(trustStoreStream, trustPassphrase);
+                    }
 
                     TrustManagerFactory tmf = TrustManagerFactory
                             .getInstance(KeyManagerFactory.getDefaultAlgorithm());