diff options
Diffstat (limited to 'components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/ElasticsearchServiceTest.java')
| -rw-r--r-- | components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/ElasticsearchServiceTest.java | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/ElasticsearchServiceTest.java b/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/ElasticsearchServiceTest.java index 9590b0a4..a51bec40 100644 --- a/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/ElasticsearchServiceTest.java +++ b/components/datalake-handler/feeder/src/test/java/org/onap/datalake/feeder/service/ElasticsearchServiceTest.java @@ -31,6 +31,7 @@ import org.mockito.Mock; import org.mockito.junit.MockitoJUnitRunner; import org.onap.datalake.feeder.config.ApplicationConfiguration; import org.onap.datalake.feeder.domain.Topic; +import org.onap.datalake.feeder.domain.TopicName; import java.io.IOException; import java.util.ArrayList; @@ -74,7 +75,7 @@ public class ElasticsearchServiceTest { public void testSaveJsons() { Topic topic = new Topic(); - topic.setName("unauthenticated.SEC_FAULT_OUTPUT"); + topic.setTopicName(new TopicName("unauthenticated.SEC_FAULT_OUTPUT")); topic.setCorrelateClearedMessage(true); topic.setMessageIdPath("/event/commonEventHeader/eventName,/event/commonEventHeader/reportingEntityName,/event/faultFields/specificProblem"); String jsonString = "{\"event\":{\"commonEventHeader\":{\"sourceId\":\"vnf_test_999\",\"startEpochMicrosec\":2222222222222,\"eventId\":\"ab305d54-85b4-a31b-7db2-fb6b9e546016\",\"sequence\":1,\"domain\":\"fautt\",\"lastEpochMicrosec\":1234567890987,\"eventName\":\"Fault_MultiCloud_VMFailure\",\"sourceName\":\"vSBC00\",\"priority\":\"Low\",\"version\":3,\"reportingEntityName\":\"vnf_test_2_rname\"},\"faultFields\":{\"eventSeverity\":\"CRITILLL\",\"alarmCondition\":\"Guest_Os_FaiLLL\",\"faultFieldsVersion\":3,\"specificProblem\":\"Fault_MultiCloud_VMFailure\",\"alarmInterfaceA\":\"aaaa\",\"alarmAdditionalInformation\":[{\"name\":\"objectType3\",\"value\":\"VIN\"},{\"name\":\"objectType4\",\"value\":\"VIN\"}],\"eventSourceType\":\"single\",\"vfStatus\":\"Active\"}}}"; @@ -86,8 +87,8 @@ public class ElasticsearchServiceTest { List<JSONObject> jsons = new ArrayList<>(); jsons.add(jsonObject); jsons.add(jsonObject2); - when(config.getElasticsearchType()).thenReturn("doc"); - when(config.isAsync()).thenReturn(true); +// when(config.getElasticsearchType()).thenReturn("doc"); + // when(config.isAsync()).thenReturn(true); elasticsearchService.saveJsons(topic.getTopicConfig(), jsons); |