X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=ONAP-PDP-REST%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fpolicy%2Fpdp%2Frest%2Fapi%2Fservices%2FNotificationService.java;h=bba51965bd6fe10d62ef83803eee4a2a6d8d15c6;hb=e0385921034ae9ce860038ea65d2d13259f7cc4c;hp=6ca52ca40ab9a183741138218246038ac740aaa3;hpb=ed2bcd773ec3dbe07311bad597ec664c4e38c009;p=policy%2Fengine.git

diff --git a/ONAP-PDP-REST/src/main/java/org/onap/policy/pdp/rest/api/services/NotificationService.java b/ONAP-PDP-REST/src/main/java/org/onap/policy/pdp/rest/api/services/NotificationService.java
index 6ca52ca40..bba51965b 100644
--- a/ONAP-PDP-REST/src/main/java/org/onap/policy/pdp/rest/api/services/NotificationService.java
+++ b/ONAP-PDP-REST/src/main/java/org/onap/policy/pdp/rest/api/services/NotificationService.java
@@ -99,7 +99,7 @@ public class NotificationService {
 			dmaapServers = XACMLProperties.getProperty(XACMLRestProperties.PROP_NOTIFICATION_SERVERS);
 			aafLogin = XACMLProperties.getProperty("DMAAP_AAF_LOGIN");
 			aafPassword = XACMLProperties.getProperty("DMAAP_AAF_PASSWORD");
-			interval = Integer.parseInt(XACMLProperties.getProperty(XACMLRestProperties.PROP_NOTIFICATION_DELAY, Integer.toString(interval)));
+            interval = Integer.parseInt(XACMLProperties.getProperty("CLIENT_INTERVAL", Integer.toString(interval)));
 			if(dmaapServers==null || aafLogin==null || aafPassword==null){
 				logger.error(XACMLErrorConstants.ERROR_DATA_ISSUE + "DMaaP properties are missing from the property file ");
 				return;
@@ -269,7 +269,7 @@ public class NotificationService {
 					Date currentTime = new Date();
 					long timeDiff = 0;
 					timeDiff = currentTime.getTime()-map.getValue().getTime();
-					if(timeDiff < (interval+1500)){
+					if(timeDiff > (interval+1500)){
 						removeTopic(map.getKey());
 					}
 				}