diff options
| author |   Shiwei Tian <tian.shiwei@zte.com.cn> | 2017-10-09 16:30:27 +0800 |
|---|---|---|
| committer | Shiwei Tian <tian.shiwei@zte.com.cn> | 2017-10-09 17:06:22 +0800 |
| commit | bfb24b1cc32e287b019fbcef89ac403a660354bb (patch) | |
| tree | c1fbf7fa71dee75c7c06c5b9075b7cfd68bd03b9 /holmes-actions/src/test | |
| parent | e0a96b91b49f9ca54827c96b2e7e7660c28fab83 (diff) | |
modify control loop name
Issue-ID: HOLMES-67
Change-Id: I3911ff57abbe87089dc3d7a2a0e1d4f14ad26cb4
Signed-off-by: Shiwei Tian <tian.shiwei@zte.com.cn>
Diffstat (limited to 'holmes-actions/src/test')
3 files changed, 3 insertions, 4 deletions
diff --git a/holmes-actions/src/test/java/org/onap/holmes/common/dcae/utils/DcaeConfigurationParserTest.java b/holmes-actions/src/test/java/org/onap/holmes/common/dcae/utils/DcaeConfigurationParserTest.java index e20ed5e..827220c 100644 --- a/holmes-actions/src/test/java/org/onap/holmes/common/dcae/utils/DcaeConfigurationParserTest.java +++ b/holmes-actions/src/test/java/org/onap/holmes/common/dcae/utils/DcaeConfigurationParserTest.java @@ -52,7 +52,6 @@ public class DcaeConfigurationParserTest { br.lines().forEach(line -> {
sb.append(line);
});
-
try {
br.close();
} catch (IOException e) {
diff --git a/holmes-actions/src/test/java/org/onap/holmes/common/dmaap/DmaapServiceTest.java b/holmes-actions/src/test/java/org/onap/holmes/common/dmaap/DmaapServiceTest.java index 7198ec8..72a0bc8 100644 --- a/holmes-actions/src/test/java/org/onap/holmes/common/dmaap/DmaapServiceTest.java +++ b/holmes-actions/src/test/java/org/onap/holmes/common/dmaap/DmaapServiceTest.java @@ -207,10 +207,10 @@ public class DmaapServiceTest { PowerMock.replayAll(); PolicyMsg actual = Whitebox - .invokeMethod(dmaapService, "getEnrichedPolicyMsg", vmEntity, vesAlarm); + .invokeMethod(dmaapService, "getEnrichedPolicyMsg", vmEntity, vesAlarm, "loopName"); PowerMock.verifyAll(); - assertThat(actual.getPolicyName(), equalTo("vLoadBalancer")); + assertThat(actual.getClosedLoopControlName(), equalTo(null)); assertThat(actual.getAai().get("vserver.prov-status"), equalTo("prov")); assertThat(actual.getAai().get("vserver.vserver-name2") == null, equalTo(true)); assertThat(actual.getAai().get("generic-vnf.service-instance-id"), equalTo("")); diff --git a/holmes-actions/src/test/resources/dcae.config.json b/holmes-actions/src/test/resources/dcae.config.json index 6fe72e8..f5aa3ae 100644 --- a/holmes-actions/src/test/resources/dcae.config.json +++ b/holmes-actions/src/test/resources/dcae.config.json @@ -1,5 +1,5 @@ {
- "holmes.default.rule.volte.scenario1": "package dcae.ves.test\nimport org.onap.some.related.packages;\nrule\"SameVNF_Relation_Rule\"\nsalience 120\nno-loop true\nwhen\n$root : VesAlarm(\n$sourceId: sourceId, sourceId != null && !sourceId.equals(\"\"),\nspecificProblem in ( \"LSS_cpiPCSCFFailReg(121297)\", \"LSS_cpiSIPRetransmitInvite(120267)\" ),\n$eventId: eventId)\n$child : VesAlarm( eventId != $eventId,\nCorrelationUtil.getInstance().isTopologicallyRelated(sourceId, $sourceId),\nspecificProblem in (\"LSS_externalLinkDown(4271)\",\"LSS_failedAttachReqsRateExceeded(4272)\"),\nthis after [-60s, 60s] $root)\nthen\nDmaapService.publishResult(...);\nend",
+ "holmes.default.rule.volte.scenario1": "loopname$$$package dcae.ves.test\nimport org.onap.some.related.packages;\nrule\"SameVNF_Relation_Rule\"\nsalience 120\nno-loop true\nwhen\n$root : VesAlarm(\n$sourceId: sourceId, sourceId != null && !sourceId.equals(\"\"),\nspecificProblem in ( \"LSS_cpiPCSCFFailReg(121297)\", \"LSS_cpiSIPRetransmitInvite(120267)\" ),\n$eventId: eventId)\n$child : VesAlarm( eventId != $eventId,\nCorrelationUtil.getInstance().isTopologicallyRelated(sourceId, $sourceId),\nspecificProblem in (\"LSS_externalLinkDown(4271)\",\"LSS_failedAttachReqsRateExceeded(4272)\"),\nthis after [-60s, 60s] $root)\nthen\nDmaapService.publishResult(...);\nend",
"collector.schema.file": "./etc/CommonEventFormat_27.2.json",
"collector.service.port": 8080,
"collector.dmaap.streamid": "fault=sec_fault,roadm-sec-to-hp|syslog=sec_syslog|heartbeat=sec_heartbeat|measurementsForVfScaling=sec_measurement|mobileFlow=sec_mobileflow|other=sec_other|stateChange=sec_statechange|thresholdCrossingAlert=sec_thresholdCrossingAlert",
|