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));
}
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
for (CorrelationRule rule : rules) {\r
if (rule.getContent() != null) {\r
deployRuleFromDB(rule.getContent());\r
+ DmaapService.loopControlNames.put(rule.getPackageName(), rule.getClosedControlLoopName());\r
}\r
}\r
}\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