diff options
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.java | 23 |
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(); |