Change-Id: I6a21707cf0475fa42aaf416088663c9f99af5a71
Issue-ID: HOLMES-82
Signed-off-by: Guangrong Fu <fu.guangrong@zte.com.cn>
try {
vesAlarmList = subscriber.subscribe();
} catch (CorrelationException e) {
try {
vesAlarmList = subscriber.subscribe();
} catch (CorrelationException e) {
- log.error("Failed polling request alarm." + e.getMessage());
+ log.error("Failed polling request alarm. " + e.getMessage());
}
vesAlarmList.forEach(vesAlarm -> droolsEngine.putRaisedIntoStream(vesAlarm));
}
}
vesAlarmList.forEach(vesAlarm -> droolsEngine.putRaisedIntoStream(vesAlarm));
}
import org.drools.runtime.rule.FactHandle;\r
import org.jvnet.hk2.annotations.Service;\r
import org.onap.holmes.common.api.stat.VesAlarm;\r
import org.drools.runtime.rule.FactHandle;\r
import org.jvnet.hk2.annotations.Service;\r
import org.onap.holmes.common.api.stat.VesAlarm;\r
+import org.onap.holmes.common.dmaap.DmaapService;\r
import org.onap.holmes.engine.request.DeployRuleRequest;\r
import org.onap.holmes.common.api.entity.CorrelationRule;\r
import org.onap.holmes.common.exception.CorrelationException;\r
import org.onap.holmes.engine.request.DeployRuleRequest;\r
import org.onap.holmes.common.api.entity.CorrelationRule;\r
import org.onap.holmes.common.exception.CorrelationException;\r
for (CorrelationRule rule : rules) {\r
if (rule.getContent() != null) {\r
deployRuleFromDB(rule.getContent());\r
for (CorrelationRule rule : rules) {\r
if (rule.getContent() != null) {\r
deployRuleFromDB(rule.getContent());\r
+ DmaapService.loopControlNames.put(rule.getPackageName(), rule.getClosedControlLoopName());\r
List<CorrelationRule> rules = new ArrayList<CorrelationRule>();\r
CorrelationRule rule = new CorrelationRule();\r
rule.setContent("content");\r
List<CorrelationRule> rules = new ArrayList<CorrelationRule>();\r
CorrelationRule rule = new CorrelationRule();\r
rule.setContent("content");\r
+ rule.setClosedControlLoopName("test");\r
+ rule.setPackageName("org.onap.holmes");\r
rules.add(rule);\r
\r
expect(ruleMgtWrapper.queryRuleByEnable(anyInt())).andReturn(rules);\r
rules.add(rule);\r
\r
expect(ruleMgtWrapper.queryRuleByEnable(anyInt())).andReturn(rules);\r