X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=mod%2Fbpgenerator%2Fonap%2Fsrc%2Ftest%2Fjava%2Forg%2Fonap%2Fblueprintgenerator%2Fservice%2Fcommon%2Fkafka%2FKafkaStreamServiceTest.java;h=54beabb761bdec8de57a1a1267a27329eb09ccc2;hb=72c2d38329865afa6692454b4fb90ab6f8a70638;hp=cad3b71732149a8a546a85a48322e0ba8d5c706c;hpb=87f19cde0f6532f5138822fa6f188b763a123235;p=dcaegen2%2Fplatform.git

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);