X-Git-Url: https://gerrit.onap.org/r/gitweb?p=holmes%2Fengine-management.git;a=blobdiff_plain;f=engine-d%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fholmes%2Fengine%2Fdmaap%2FSubscriberAction.java;fp=engine-d%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fholmes%2Fengine%2Fdmaap%2FSubscriberAction.java;h=035b796e68b86d3aa0dedf0216d841d48119a2db;hp=21f5961b1a7ec3a429ba061c94a7830928a309af;hb=b7f3d4425348905ad0e7ead67eb51c45048b48a4;hpb=89b122983361d25d3208330c588b921c5804c5e9 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 21f5961..035b796 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 @@ -1,5 +1,5 @@ /* - * Copyright 2017 - 2022 ZTE Corporation. + * Copyright 2017-2022 ZTE Corporation. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -17,10 +17,8 @@ package org.onap.holmes.engine.dmaap; import jakarta.annotation.PreDestroy; import lombok.extern.slf4j.Slf4j; -import org.onap.holmes.common.database.DbDaoUtil; import org.onap.holmes.dsa.dmaappolling.Subscriber; import org.onap.holmes.engine.db.AlarmInfoDaoService; -import org.onap.holmes.engine.db.jdbi.AlarmInfoDao; import org.onap.holmes.engine.manager.DroolsEngine; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @@ -36,8 +34,6 @@ public class SubscriberAction { @Autowired private DroolsEngine droolsEngine; @Autowired - private DbDaoUtil daoUtil; - @Autowired private AlarmInfoDaoService alarmInfoDaoService; private HashMap pollingTasks = new HashMap<>(); @@ -48,7 +44,6 @@ public class SubscriberAction { if (pollingTasks.containsKey(topic)) { removeSubscriber(subscriber); } - AlarmInfoDao alarmInfoDao = daoUtil.getJdbiDaoByOnDemand(AlarmInfoDao.class); DMaaPAlarmPolling pollingTask = new DMaaPAlarmPolling(subscriber, droolsEngine, alarmInfoDaoService); Thread thread = new Thread(pollingTask); thread.start();