summaryrefslogtreecommitdiffstats
path: root/engine-d/src/main/java/org/onap/holmes/engine/dcaepolling/DcaeConfigurationPolling.java
diff options
context:
space:
mode:
Diffstat (limited to 'engine-d/src/main/java/org/onap/holmes/engine/dcaepolling/DcaeConfigurationPolling.java')
-rw-r--r--engine-d/src/main/java/org/onap/holmes/engine/dcaepolling/DcaeConfigurationPolling.java1
1 files changed, 1 insertions, 0 deletions
diff --git a/engine-d/src/main/java/org/onap/holmes/engine/dcaepolling/DcaeConfigurationPolling.java b/engine-d/src/main/java/org/onap/holmes/engine/dcaepolling/DcaeConfigurationPolling.java
index 23030d2..9fa153e 100644
--- a/engine-d/src/main/java/org/onap/holmes/engine/dcaepolling/DcaeConfigurationPolling.java
+++ b/engine-d/src/main/java/org/onap/holmes/engine/dcaepolling/DcaeConfigurationPolling.java
@@ -56,6 +56,7 @@ public class DcaeConfigurationPolling implements Runnable{
SubscriberAction subscriberAction = ServiceLocatorHolder.getLocator()
.getService(SubscriberAction.class);
Subscriber subscriber = new Subscriber();
+ subscriber.setTopic(subscriberKey);
subscriber.setUrl(dcaeConfigurations.getSubSecInfo(subscriberKey).getDmaapInfo()
.getTopicUrl());
subscriberAction.addSubscriber(subscriber);