From b7f3d4425348905ad0e7ead67eb51c45048b48a4 Mon Sep 17 00:00:00 2001 From: Guangrong Fu Date: Wed, 17 Aug 2022 16:18:25 +0800 Subject: bugfix - added transactionID Issue-ID: HOLMES-563 Signed-off-by: Guangrong Fu Change-Id: Ibd87fb819ffb49a641b89d2597c220a2d898cf42 --- .../main/java/org/onap/holmes/engine/dmaap/SubscriberAction.java | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) (limited to 'engine-d/src/main/java/org/onap') 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(); -- cgit 1.2.3-korg