diff options
Diffstat (limited to 'src/main/java/org/onap/dcaegen2/services/sonhms/MainThreadComponent.java')
| -rw-r--r-- | src/main/java/org/onap/dcaegen2/services/sonhms/MainThreadComponent.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/MainThreadComponent.java b/src/main/java/org/onap/dcaegen2/services/sonhms/MainThreadComponent.java index e809b45..608e95b 100644 --- a/src/main/java/org/onap/dcaegen2/services/sonhms/MainThreadComponent.java +++ b/src/main/java/org/onap/dcaegen2/services/sonhms/MainThreadComponent.java @@ -82,7 +82,7 @@ public class MainThreadComponent { Long difference = fixedPciCreatedAt.getTime() - lastInvokedOofTimeStamp.getTime(); Configuration configuration = Configuration.getInstance(); - if (difference > configuration.getPolicyFixedPciTimeInterval()) { + if (Math.abs(difference) > configuration.getPolicyFixedPciTimeInterval()) { log.info("Creating new child thread for sending fixedPciCells"); List<Graph> cluster = new ArrayList<>(); BlockingQueue<List<String>> childStatusQueue = new LinkedBlockingQueue<>(); |