aboutsummaryrefslogtreecommitdiffstats
path: root/src/main/java/org/onap/dcaegen2/services/sonhms/MainThreadComponent.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/org/onap/dcaegen2/services/sonhms/MainThreadComponent.java')
-rw-r--r--src/main/java/org/onap/dcaegen2/services/sonhms/MainThreadComponent.java12
1 files changed, 10 insertions, 2 deletions
diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/MainThreadComponent.java b/src/main/java/org/onap/dcaegen2/services/sonhms/MainThreadComponent.java
index 1b4ff26..606f420 100644
--- a/src/main/java/org/onap/dcaegen2/services/sonhms/MainThreadComponent.java
+++ b/src/main/java/org/onap/dcaegen2/services/sonhms/MainThreadComponent.java
@@ -34,7 +34,13 @@ public class MainThreadComponent {
private static Logger log = LoggerFactory.getLogger(MainThreadComponent.class);
@Autowired
- private NewNotification newNotification;
+ private NewSdnrNotification newNotification;
+
+ @Autowired
+ private NewPmNotification newPmNotification;
+
+ @Autowired
+ private NewFmNotification newFmNotification;
/**
* main thread initialization.
@@ -42,7 +48,9 @@ public class MainThreadComponent {
@PostConstruct
public void init() {
log.debug("initializing main thread");
- Thread thread = new Thread(new MainThread(newNotification));
+ Thread thread = new Thread(new MainThread(newNotification, newFmNotification));
thread.start();
+ Thread pmThread = new Thread(new PMThread(newPmNotification));
+ pmThread.start();
}
}