PolicyMsg policyMsg = new PolicyMsg();
policyMsg.setClosedLoopEventStatus(EVENT_STATUS.ONSET);
PowerMock.expectNew(Publisher.class).andReturn(publisher);
- EasyMock.expect(publisher.publish(policyMsg)).andReturn(true);
+ publisher.publish(policyMsg);
+ EasyMock.expectLastCall();
DcaeConfigurationsCache.setDcaeConfigurations(
DcaeConfigurationParser.parse(readConfigurationsFromFile("dcae.config.json")));
policyMsg.setRequestID("testRequestid");
uniqueRequestIdCache.put("testAlarmId", "testRequestid");
PowerMock.expectNew(Publisher.class).andReturn(publisher);
- EasyMock.expect(publisher.publish(policyMsg)).andReturn(true);
+ publisher.publish(policyMsg);
+ EasyMock.expectLastCall();
DcaeConfigurationsCache.setDcaeConfigurations(
DcaeConfigurationParser.parse(readConfigurationsFromFile("dcae.config.json")));