starts threads each for every supported collector

Make code changes so that mapper starts one thread each for every supported collector as per configuration

Change-Id: I90d3b9d27d0d64107b1b33c6752dc2f0c49344de
Issue-ID: DCAEGEN2-1174
Signed-off-by: amshegokar <AS00500801@techmahindra.com>

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;
+	}
 
 }