X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=engine-d%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fholmes%2Fengine%2Fdcaepolling%2FDcaeConfigurationPolling.java;h=9fa153ecf43e352f6fabf62582bd84eb0c832a1e;hb=517b9b3e72b78e5bd537b0abe7d348fd1d642080;hp=23030d25b466467092822479121c411fa8ff3699;hpb=4383d0f0649f68d418aa5351917b7755266a2b7a;p=holmes%2Fengine-management.git 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);