diff options
Diffstat (limited to 'mod/bpgenerator/onap/src/test/java/org/onap/blueprintgenerator/service/common')
4 files changed, 20 insertions, 22 deletions
diff --git a/mod/bpgenerator/onap/src/test/java/org/onap/blueprintgenerator/service/common/AppConfigServiceTest.java b/mod/bpgenerator/onap/src/test/java/org/onap/blueprintgenerator/service/common/AppConfigServiceTest.java index 61f9353..86e304e 100644 --- a/mod/bpgenerator/onap/src/test/java/org/onap/blueprintgenerator/service/common/AppConfigServiceTest.java +++ b/mod/bpgenerator/onap/src/test/java/org/onap/blueprintgenerator/service/common/AppConfigServiceTest.java @@ -27,7 +27,6 @@ import static org.junit.Assert.assertEquals; import static org.mockito.Mockito.when; import java.util.HashMap; -import java.util.LinkedHashMap; import java.util.Map; import org.junit.Before; import org.junit.Test; @@ -84,7 +83,7 @@ public class AppConfigServiceTest { public void shouldCreateStringInputForStringParameter() { mockParameters(PARAMETERS_TYPE_STRING, TEST_STRING_VALUE); - Map<String, LinkedHashMap<String, Object>> inputs = new HashMap<>(); + Map<String, Map<String, Object>> inputs = new HashMap<>(); Map<String, Object> appConfig = appConfigService.createAppconfig(inputs, componentSpec, false); Map<String, Object> createdInputs = (Map<String, Object>) appConfig.get(INPUTS); @@ -99,7 +98,7 @@ public class AppConfigServiceTest { public void shouldCreateStringInputForUnknownParameter() { mockParameters(UNKNOWN_TYPE, TEST_STRING_VALUE); - Map<String, LinkedHashMap<String, Object>> inputs = new HashMap<>(); + Map<String, Map<String, Object>> inputs = new HashMap<>(); Map<String, Object> appConfig = appConfigService.createAppconfig(inputs, componentSpec, false); Map<String, Object> createdInputs = (Map<String, Object>) appConfig.get(INPUTS); @@ -114,7 +113,7 @@ public class AppConfigServiceTest { public void shouldCreateBooleanInputForBooleanParameter() { mockParameters(PARAMETERS_TYPE_BOOLEAN, BOOLEAN_TEST_VALUE); - Map<String, LinkedHashMap<String, Object>> inputs = new HashMap<>(); + Map<String, Map<String, Object>> inputs = new HashMap<>(); Map<String, Object> appConfig = appConfigService.createAppconfig(inputs, componentSpec, false); Map<String, Object> createdInputs = (Map<String, Object>) appConfig.get(INPUTS); @@ -129,7 +128,7 @@ public class AppConfigServiceTest { public void shouldCreateIntegerInputForIntegerParameter() { mockParameters(PARAMETERS_TYPE_INTEGER, 123); - Map<String, LinkedHashMap<String, Object>> inputs = new HashMap<>(); + Map<String, Map<String, Object>> inputs = new HashMap<>(); Map<String, Object> appConfig = appConfigService.createAppconfig(inputs, componentSpec, false); Map<String, Object> createdInputs = (Map<String, Object>) appConfig.get(INPUTS); @@ -144,7 +143,7 @@ public class AppConfigServiceTest { public void shouldCreateIntegerInputForNumberParameter() { mockParameters(PARAMETERS_TYPE_NUMBER, 123); - Map<String, LinkedHashMap<String, Object>> inputs = new HashMap<>(); + Map<String, Map<String, Object>> inputs = new HashMap<>(); Map<String, Object> appConfig = appConfigService.createAppconfig(inputs, componentSpec, false); Map<String, Object> createdInputs = (Map<String, Object>) appConfig.get(INPUTS); diff --git a/mod/bpgenerator/onap/src/test/java/org/onap/blueprintgenerator/service/common/PropertiesServiceTest.java b/mod/bpgenerator/onap/src/test/java/org/onap/blueprintgenerator/service/common/PropertiesServiceTest.java index a598315..468a402 100644 --- a/mod/bpgenerator/onap/src/test/java/org/onap/blueprintgenerator/service/common/PropertiesServiceTest.java +++ b/mod/bpgenerator/onap/src/test/java/org/onap/blueprintgenerator/service/common/PropertiesServiceTest.java @@ -128,7 +128,7 @@ public class PropertiesServiceTest { OnapComponentSpec onapComponentSpec = getOnapComponentSpecWithStreamsPublishes(); Publishes publishes = onapComponentSpec.getStreams().getPublishes()[0]; when(blueprintHelperService.isMessageRouterType(eq(publishes.getType()))).thenReturn(true); - when(streamsService.createStreams(any(), eq(publishes.getConfig_key() + Constants._TOPIC), + when(streamsService.createStreams(any(), eq(publishes.getConfig_key() + Constants.A_TOPIC), eq(publishes.getType()), eq(publishes.getConfig_key()), eq(publishes.getRoute()), @@ -153,7 +153,7 @@ public class PropertiesServiceTest { OnapComponentSpec onapComponentSpec = getOnapComponentSpecWithStreamsPublishes(); Publishes publishes = onapComponentSpec.getStreams().getPublishes()[0]; when(blueprintHelperService.isDataRouterType(eq(publishes.getType()))).thenReturn(true); - when(streamsService.createStreams(any(), eq(publishes.getConfig_key() + Constants._FEED), + when(streamsService.createStreams(any(), eq(publishes.getConfig_key() + Constants.A_FEED), eq(publishes.getType()), eq(publishes.getConfig_key()), eq(publishes.getRoute()), @@ -178,7 +178,7 @@ public class PropertiesServiceTest { OnapComponentSpec onapComponentSpec = getOnapComponentSpecWithStreamsSubscribes(); Subscribes subscribes = onapComponentSpec.getStreams().getSubscribes()[0]; when(blueprintHelperService.isMessageRouterType(eq(subscribes.getType()))).thenReturn(true); - when(streamsService.createStreams(any(), eq(subscribes.getConfig_key() + Constants._TOPIC), + when(streamsService.createStreams(any(), eq(subscribes.getConfig_key() + Constants.A_TOPIC), eq(subscribes.getType()), eq(subscribes.getConfig_key()), eq(subscribes.getRoute()), @@ -203,7 +203,7 @@ public class PropertiesServiceTest { OnapComponentSpec onapComponentSpec = getOnapComponentSpecWithStreamsSubscribes(); Subscribes subscribes = onapComponentSpec.getStreams().getSubscribes()[0]; when(blueprintHelperService.isDataRouterType(eq(subscribes.getType()))).thenReturn(true); - when(streamsService.createStreams(any(), eq(subscribes.getConfig_key() + Constants._FEED), + when(streamsService.createStreams(any(), eq(subscribes.getConfig_key() + Constants.A_FEED), eq(subscribes.getType()), eq(subscribes.getConfig_key()), eq(subscribes.getRoute()), diff --git a/mod/bpgenerator/onap/src/test/java/org/onap/blueprintgenerator/service/common/StreamServiceTest.java b/mod/bpgenerator/onap/src/test/java/org/onap/blueprintgenerator/service/common/StreamServiceTest.java index fe93f5f..d2936da 100644 --- a/mod/bpgenerator/onap/src/test/java/org/onap/blueprintgenerator/service/common/StreamServiceTest.java +++ b/mod/bpgenerator/onap/src/test/java/org/onap/blueprintgenerator/service/common/StreamServiceTest.java @@ -279,11 +279,11 @@ class StreamServiceTest { return subscribes; } - private Map<String, LinkedHashMap<String, Object>> createInputs() { - LinkedHashMap<String, Object> map = new LinkedHashMap<>(); + private Map<String, Map<String, Object>> createInputs() { + Map<String, Object> map = new LinkedHashMap<>(); map.put("key-1", "obj-1"); - Map<String, LinkedHashMap<String, Object>> mapsMap = new HashMap<>(); + Map<String, Map<String, Object>> mapsMap = new HashMap<>(); mapsMap.put("inputs", map); return mapsMap; } diff --git a/mod/bpgenerator/onap/src/test/java/org/onap/blueprintgenerator/service/common/kafka/KafkaStreamServiceTest.java b/mod/bpgenerator/onap/src/test/java/org/onap/blueprintgenerator/service/common/kafka/KafkaStreamServiceTest.java index cad3b71..54beabb 100644 --- a/mod/bpgenerator/onap/src/test/java/org/onap/blueprintgenerator/service/common/kafka/KafkaStreamServiceTest.java +++ b/mod/bpgenerator/onap/src/test/java/org/onap/blueprintgenerator/service/common/kafka/KafkaStreamServiceTest.java @@ -27,7 +27,6 @@ import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertNotNull; import static org.junit.Assert.assertTrue; -import java.util.LinkedHashMap; import java.util.Map; import org.junit.Test; @@ -55,12 +54,12 @@ public class KafkaStreamServiceTest { @Test public void createCorrectStreamCommonInputs() { - Map<String, LinkedHashMap<String, Object>> publishInputs = kafkaStreamService + Map<String, Map<String, Object>> publishInputs = kafkaStreamService .createStreamPublishInputs("test_stream_name"); - LinkedHashMap<String, Object> kafka_bootstrap_servers = publishInputs.get("kafka_bootstrap_servers"); - LinkedHashMap<String, Object> kafka_username = publishInputs.get("kafka_username"); - LinkedHashMap<String, Object> kafka_password = publishInputs.get("kafka_password"); + Map<String, Object> kafka_bootstrap_servers = publishInputs.get("kafka_bootstrap_servers"); + Map<String, Object> kafka_username = publishInputs.get("kafka_username"); + Map<String, Object> kafka_password = publishInputs.get("kafka_password"); assertNotNull(kafka_bootstrap_servers); assertNotNull(kafka_username); @@ -73,10 +72,10 @@ public class KafkaStreamServiceTest { @Test public void createCorrectStreamPublishInput() { - Map<String, LinkedHashMap<String, Object>> publishInputs = kafkaStreamService + Map<String, Map<String, Object>> publishInputs = kafkaStreamService .createStreamPublishInputs(TEST_STREAM_NAME); - LinkedHashMap<String, Object> kafka_stream_name = publishInputs.get(TEST_STREAM_NAME + PUBLISH_URL_SUFFIX); + Map<String, Object> kafka_stream_name = publishInputs.get(TEST_STREAM_NAME + PUBLISH_URL_SUFFIX); assertNotNull(kafka_stream_name); @@ -85,10 +84,10 @@ public class KafkaStreamServiceTest { @Test public void createCorrectStreamSubscribeInput() { - Map<String, LinkedHashMap<String, Object>> publishInputs = kafkaStreamService + Map<String, Map<String, Object>> publishInputs = kafkaStreamService .createStreamSubscribeInputs(TEST_STREAM_NAME); - LinkedHashMap<String, Object> kafka_stream_name = publishInputs.get(TEST_STREAM_NAME + SUBSCRIBE_URL_SUFFIX); + Map<String, Object> kafka_stream_name = publishInputs.get(TEST_STREAM_NAME + SUBSCRIBE_URL_SUFFIX); assertNotNull(kafka_stream_name); |