diff options
Diffstat (limited to 'UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/dmaap/Creator.java')
-rw-r--r-- | UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/dmaap/Creator.java | 26 |
1 files changed, 9 insertions, 17 deletions
diff --git a/UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/dmaap/Creator.java b/UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/dmaap/Creator.java index 98191f7..ce75a6e 100644 --- a/UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/dmaap/Creator.java +++ b/UniversalVesAdapter/src/main/java/org/onap/universalvesadapter/dmaap/Creator.java @@ -39,30 +39,15 @@ public class Creator { private DMaaPMRFactory dMaaPMRFactoryInstance; private String dmaaphost; private String publisherTopic; - private String subcriberTopic; + @Autowired private DmaapConfig dmaapConfig; - @Autowired - public void setDmaapConfig(DmaapConfig dmaapConfig) { - this.dmaapConfig = dmaapConfig; - } - - public DmaapConfig getDmaapConfig() { - return dmaapConfig; - } - - - public Creator() { - - } - // prop initializer public void propertyFileInitializer() { this.dmaaphost = dmaapConfig.getDmaaphost(); this.publisherTopic = dmaapConfig.getPublisherTopic(); - this.subcriberTopic = dmaapConfig.getSubscriberTopic(); this.dMaaPMRFactoryInstance = DMaaPMRFactory.create(); debugLogger.info("The Hostname of DMaap is :" + dmaaphost); @@ -82,7 +67,7 @@ public class Creator { } // subscriber - public DMaaPMRSubscriber getDMaaPMRSubscriber(){ + public DMaaPMRSubscriber getDMaaPMRSubscriber(String subcriberTopic){ propertyFileInitializer(); DMaaPMRSubscriberConfig dMaaPMRSubscriberConfig = null; try { @@ -95,5 +80,12 @@ public class Creator { return dMaaPMRFactoryInstance.createSubscriber(dMaaPMRSubscriberConfig); } + public void setDmaapConfig(DmaapConfig dmaapConfig) { + this.dmaapConfig = dmaapConfig; + } + + public DmaapConfig getDmaapConfig() { + return dmaapConfig; + } } |