diff --git a/financial-services-accelerator/components/org.wso2.financial.services.accelerator.event.notifications.service/src/main/java/org/wso2/financial/services/accelerator/event/notifications/service/EventSubscriptionService.java b/financial-services-accelerator/components/org.wso2.financial.services.accelerator.event.notifications.service/src/main/java/org/wso2/financial/services/accelerator/event/notifications/service/EventSubscriptionService.java index 4a4f6499..0c7db316 100644 --- a/financial-services-accelerator/components/org.wso2.financial.services.accelerator.event.notifications.service/src/main/java/org/wso2/financial/services/accelerator/event/notifications/service/EventSubscriptionService.java +++ b/financial-services-accelerator/components/org.wso2.financial.services.accelerator.event.notifications.service/src/main/java/org/wso2/financial/services/accelerator/event/notifications/service/EventSubscriptionService.java @@ -70,6 +70,7 @@ public EventSubscription createEventSubscription(EventSubscription eventSubscrip DatabaseUtils.rollbackTransaction(connection); throw new FSEventNotificationException(EventNotificationConstants.ERROR_STORING_EVENT_SUBSCRIPTION, e); } finally { + log.debug(EventNotificationConstants.DATABASE_CONNECTION_CLOSE_LOG_MSG); DatabaseUtils.closeConnection(connection); } } @@ -102,6 +103,7 @@ public EventSubscription getEventSubscriptionBySubscriptionId(String subscriptio DatabaseUtils.rollbackTransaction(connection); throw new FSEventNotificationException(e.getMessage(), e); } finally { + log.debug(EventNotificationConstants.DATABASE_CONNECTION_CLOSE_LOG_MSG); DatabaseUtils.closeConnection(connection); } } @@ -132,6 +134,7 @@ public List getEventSubscriptionsByClientId(String clientId) DatabaseUtils.rollbackTransaction(connection); throw new FSEventNotificationException(e.getMessage(), e); } finally { + log.debug(EventNotificationConstants.DATABASE_CONNECTION_CLOSE_LOG_MSG); DatabaseUtils.closeConnection(connection); } } @@ -163,6 +166,7 @@ public List getEventSubscriptionsByEventType(String eventType DatabaseUtils.rollbackTransaction(connection); throw new FSEventNotificationException(e.getMessage(), e); } finally { + log.debug(EventNotificationConstants.DATABASE_CONNECTION_CLOSE_LOG_MSG); DatabaseUtils.closeConnection(connection); } } @@ -223,6 +227,7 @@ public Boolean updateEventSubscription(EventSubscription eventSubscription) DatabaseUtils.rollbackTransaction(connection); throw new FSEventNotificationException(e.getMessage(), e); } finally { + log.debug(EventNotificationConstants.DATABASE_CONNECTION_CLOSE_LOG_MSG); DatabaseUtils.closeConnection(connection); } } @@ -254,6 +259,7 @@ public Boolean deleteEventSubscription(String subscriptionId) throws FSEventNoti DatabaseUtils.rollbackTransaction(connection); throw new FSEventNotificationException(e.getMessage(), e); } finally { + log.debug(EventNotificationConstants.DATABASE_CONNECTION_CLOSE_LOG_MSG); DatabaseUtils.closeConnection(connection); } }