diff options
Diffstat (limited to 'engine-d/src/main/java/org/onap/holmes/engine/dmaappolling/SubscriberAction.java')
-rw-r--r-- | engine-d/src/main/java/org/onap/holmes/engine/dmaappolling/SubscriberAction.java | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/engine-d/src/main/java/org/onap/holmes/engine/dmaappolling/SubscriberAction.java b/engine-d/src/main/java/org/onap/holmes/engine/dmaappolling/SubscriberAction.java index ef585d5..da83683 100644 --- a/engine-d/src/main/java/org/onap/holmes/engine/dmaappolling/SubscriberAction.java +++ b/engine-d/src/main/java/org/onap/holmes/engine/dmaappolling/SubscriberAction.java @@ -35,19 +35,19 @@ public class SubscriberAction { private ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor(); public void addSubscriber(Subscriber subscriber) { - if (!pollingRequests.containsKey(subscriber.getUrl())) { + if (!pollingRequests.containsKey(subscriber.getTopic())) { DMaaPPollingRequest pollingTask = new DMaaPPollingRequest(subscriber, droolsEngine); ScheduledFuture future = service .scheduleAtFixedRate(pollingTask, 0, subscriber.getPeriod(), TimeUnit.MILLISECONDS); - pollingRequests.put(subscriber.getUrl(), future); + pollingRequests.put(subscriber.getTopic(), future); } } public void removeSubscriber(Subscriber subscriber) { - ScheduledFuture future = pollingRequests.get(subscriber.getUrl()); + ScheduledFuture future = pollingRequests.get(subscriber.getTopic()); if (future != null) { future.cancel(true); } - pollingRequests.remove(subscriber.getUrl()); + pollingRequests.remove(subscriber.getTopic()); } } |