summaryrefslogtreecommitdiffstats
path: root/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/MainThread.java
diff options
context:
space:
mode:
Diffstat (limited to 'components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/MainThread.java')
-rw-r--r--components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/MainThread.java23
1 files changed, 8 insertions, 15 deletions
diff --git a/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/MainThread.java b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/MainThread.java
index 925a196f..57a831ea 100644
--- a/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/MainThread.java
+++ b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/MainThread.java
@@ -21,35 +21,28 @@
package org.onap.slice.analysis.ms;
-import javax.annotation.PostConstruct;
-
-import org.onap.slice.analysis.ms.dmaap.NewPmNotification;
import org.onap.slice.analysis.ms.service.ConsumerThread;
import org.onap.slice.analysis.ms.service.PmThread;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
/**
* This class starts the pm thread and consumer thread
*/
-@Component
public class MainThread {
private static Logger log = LoggerFactory.getLogger(MainThread.class);
-
- @Autowired
- private NewPmNotification newPmNotification;
-
-
+
+ private MainThread() {
+
+ }
+
/**
* main thread initialization.
*/
- @PostConstruct
- public void init() {
- log.debug("initializing main thread");
- Thread pmThread = new Thread(new PmThread(newPmNotification));
+ public static void initiateThreads() {
+ log.debug("initializing Pm thread & Consumer thread");
+ Thread pmThread = new Thread(new PmThread());
pmThread.start();
Thread consumerThread = new Thread(new ConsumerThread());
consumerThread.start();