diff --git a/mediation-old/src/main/java/com/wso2telco/dep/mediator/dao/SMSMessagingDAO.java b/mediation-old/src/main/java/com/wso2telco/dep/mediator/dao/SMSMessagingDAO.java
index c75555b..c724807 100644
--- a/mediation-old/src/main/java/com/wso2telco/dep/mediator/dao/SMSMessagingDAO.java
+++ b/mediation-old/src/main/java/com/wso2telco/dep/mediator/dao/SMSMessagingDAO.java
@@ -652,6 +652,9 @@ public void insertSMSRequestIds(String requestId, String senderAddress, Map<Stri
 				ps.addBatch();
 			}
 			
+			gatewayRequestIds.clear();
+			queryString.setLength(0);
+			
 			log.debug("sql query in insertSMSRequestIds : " + ps);
 
 			ps.executeBatch();
@@ -679,7 +682,7 @@ public void insertSMSRequestIds(String requestId, String senderAddress, Map<Stri
 			log.error("error in insertSMSRequestIds : ", e);
 			throw e;
 		} finally {
-
+		
 			DbUtils.closeAllConnections(ps, con, null);
 		}
 	}
diff --git a/mediation-old/src/main/java/com/wso2telco/dep/mediator/impl/smsmessaging/SendSMSRequestIdPersistMediator.java b/mediation-old/src/main/java/com/wso2telco/dep/mediator/impl/smsmessaging/SendSMSRequestIdPersistMediator.java
index 5594347..923bafe 100644
--- a/mediation-old/src/main/java/com/wso2telco/dep/mediator/impl/smsmessaging/SendSMSRequestIdPersistMediator.java
+++ b/mediation-old/src/main/java/com/wso2telco/dep/mediator/impl/smsmessaging/SendSMSRequestIdPersistMediator.java
@@ -76,6 +76,7 @@ public boolean mediate(MessageContext messageContext) {
 
         try {
             new SMSMessagingService().insertSMSRequestIds(requestId, senderAddress, addressToOperatorRequestIdMap);
+            addressToOperatorRequestIdMap.clear();
         } catch (BusinessException e) {
             log.error("Error inserting request ids for send SMS operation", e);
             return false;