Merge pull request #69 from urviljoshi/connection-issue

table results closed
mosip · Aug 17, 2021 · cc94503 · cc94503
2 parents ab13241 + b35390f
commit cc94503
Show file tree

Hide file tree

Showing 4 changed files with 12 additions and 0 deletions.
diff --git a/src/repository/deliveryreportpersistence.bal b/src/repository/deliveryreportpersistence.bal
@@ -86,6 +86,7 @@ public type DeliveryReportPersistence object {
                     log:printError("Error retreiving failed delivery from subID from the database: " + errCause);
                 }
             }
+            dbResult.close();
         } else {
             string errCause = <string>dbResult.detail()?.message;
             log:printError("Error retreiving data from the database: " + errCause);

diff --git a/src/repository/hubpersistenceimpl.bal b/src/repository/hubpersistenceimpl.bal
@@ -55,6 +55,7 @@ public type HubPersistenceImpl object {
                     callbackParameter, secret, leaseSeconds, createdAt, createdBy, createdDTimes, updatedBy, updatedDTimes);
                 self.handleUpdate(returned, "insert new subs");
             }
+            dbResult.close();
         } else {
             string errCause = <string>dbResult.detail()?.message;
             log:printError("Error retreiving data from the database: " + errCause);
@@ -86,6 +87,7 @@ public type HubPersistenceImpl object {
                     subscriptionResult = subscriptionDeletedDetails;
                 }
             }
+            dbResult.close();
         }
 
         jdbc:Parameter id = {sqlType: jdbc:TYPE_VARCHAR, value: subscriptionResult.id};
@@ -170,6 +172,7 @@ public type HubPersistenceImpl object {
                     log:printError("Error retreiving subscription details from the database: " + errCause);
                 }
             }
+            dbResult.close();
         } else {
             string errCause = <string>dbResult.detail()?.message;
             log:printError("Error retreiving data from the database: " + errCause);
@@ -198,6 +201,7 @@ public type HubPersistenceImpl object {
                     log:printError("Error retreiving topic registration details from the database: " + errCause);
                 }
             }
+            dbResult.close();
         } else {
             string errCause = <string>dbResult.detail()?.message;
             log:printError("Error retreiving data from the database: " + errCause);

diff --git a/src/repository/msgpersistence.bal b/src/repository/msgpersistence.bal
@@ -51,6 +51,7 @@ public type MessagePersistenceImpl object {
                     log:printError("Error retreiving topic registration details from the database: " + errCause);
                 }
             }
+            dbResult.close();
         } else {
             string errCause = <string>dbResult.detail()?.message;
             log:printError("Error retreiving data from the database: " + errCause);
@@ -77,6 +78,7 @@ public type MessagePersistenceImpl object {
                     log:printError("Error retreiving topic registration details from the database: " + errCause);
                 }
             }
+            dbResult.close();
         } else {
             string errCause = <string>dbResult.detail()?.message;
             log:printError("Error retreiving data from the database: " + errCause);
@@ -122,6 +124,7 @@ public type MessagePersistenceImpl object {
                     log:printError("Error retreiving failed delivery from subID from the database: " + errCause);
                 }
             }
+            dbResult.close();
         } else {
             string errCause = <string>dbResult.detail()?.message;
             log:printError("Error retreiving data from the database: " + errCause);
@@ -167,6 +170,7 @@ public type MessagePersistenceImpl object {
                     log:printError("Error retreiving unsend messaged from message store: " + errCause);
                 }
             }
+            dbResult.close();
         } else {
             string errCause = <string>dbResult.detail()?.message;
             log:printError("Error retreiving data from the database: " + errCause);

diff --git a/src/repository/subscriptionoperations.bal b/src/repository/subscriptionoperations.bal
@@ -28,6 +28,7 @@ public type SubsOperations object {
                     log:printError("Error retreiving topic registration details from the database: " + errCause);
                 }
             }
+            dbResult.close();
         } else {
             string errCause = <string>dbResult.detail()?.message;
             log:printError("Error retreiving data from the database: " + errCause);
@@ -55,6 +56,7 @@ public type SubsOperations object {
                     log:printError("Error retreiving topic registration details from the database: " + errCause);
                 }
             }
+            dbResult.close();
         } else {
             string errCause = <string>dbResult.detail()?.message;
             log:printError("Error retreiving data from the database: " + errCause);
@@ -84,6 +86,7 @@ public type SubsOperations object {
                     log:printError("Error retreiving topic registration details from the database: " + errCause);
                 }
             }
+            dbResult.close();
         } else {
             string errCause = <string>dbResult.detail()?.message;
             log:printError("Error retreiving data from the database: " + errCause);