diff options
author | Fei Tang <tang.fei4@zte.com.cn> | 2018-03-28 08:25:04 +0800 |
---|---|---|
committer | Fei Tang <tang.fei4@zte.com.cn> | 2018-03-28 08:25:04 +0800 |
commit | 43f5b3a0ddb7f22b3c29a4f042991155a46e41d6 (patch) | |
tree | 2e62e86ef13f91cff21244161671c5abb1b4c2b0 /engine-d/src/main/java/org/onap/holmes/engine/dmaap/SubscriberAction.java | |
parent | 39a1d413420242ceef377f319d3c3f5dc8034398 (diff) |
add alarm synchronization related operation
Issue-ID: HOLMES-106
Change-Id: Idb47aa0726c0c8fc179c085381092e01d7a26fb3
Signed-off-by: Fei Tang <tang.fei4@zte.com.cn>
Diffstat (limited to 'engine-d/src/main/java/org/onap/holmes/engine/dmaap/SubscriberAction.java')
-rw-r--r-- | engine-d/src/main/java/org/onap/holmes/engine/dmaap/SubscriberAction.java | 7 |
1 files changed, 6 insertions, 1 deletions
diff --git a/engine-d/src/main/java/org/onap/holmes/engine/dmaap/SubscriberAction.java b/engine-d/src/main/java/org/onap/holmes/engine/dmaap/SubscriberAction.java index c2fa5b8..b02cbe4 100644 --- a/engine-d/src/main/java/org/onap/holmes/engine/dmaap/SubscriberAction.java +++ b/engine-d/src/main/java/org/onap/holmes/engine/dmaap/SubscriberAction.java @@ -23,7 +23,9 @@ import javax.annotation.PreDestroy; import javax.inject.Inject; import lombok.extern.slf4j.Slf4j; import org.jvnet.hk2.annotations.Service; +import org.onap.holmes.common.utils.DbDaoUtil; import org.onap.holmes.dsa.dmaappolling.Subscriber; +import org.onap.holmes.engine.db.AlarmInfoDao; import org.onap.holmes.engine.manager.DroolsEngine; @Service @@ -32,12 +34,15 @@ public class SubscriberAction { @Inject private DroolsEngine droolsEngine; + @Inject + private DbDaoUtil daoUtil; private HashMap<String, DMaaPAlarmPolling> pollingTasks = new HashMap<>(); public synchronized void addSubscriber(Subscriber subscriber) { String topic = subscriber.getTopic(); if (topic != null && !pollingTasks.containsKey(topic)) { - DMaaPAlarmPolling pollingTask = new DMaaPAlarmPolling(subscriber, droolsEngine); + AlarmInfoDao alarmInfoDao = daoUtil.getJdbiDaoByOnDemand(AlarmInfoDao.class); + DMaaPAlarmPolling pollingTask = new DMaaPAlarmPolling(subscriber, droolsEngine, alarmInfoDao); Thread thread = new Thread(pollingTask); thread.start(); pollingTasks.put(topic, pollingTask); |