Fix sonar issues

[dcaegen2/platform.git] / mod / bpgenerator / onap / src / main / java / org / onap / blueprintgenerator / service / common / kafka / KafkaStreamService.java

diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/kafka/KafkaStreamService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/kafka/KafkaStreamService.java
index 2090ef0..c36387c 100644 (file)
--- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/kafka/KafkaStreamService.java
+++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/common/kafka/KafkaStreamService.java
@@ -59,7 +59,7 @@ public class KafkaStreamService {
      * @param streamName Stream name
      * @return
      */
-    public Map<String, LinkedHashMap<String, Object>> createStreamPublishInputs(String streamName) {
+    public Map<String, Map<String, Object>> createStreamPublishInputs(String streamName) {
         return createStreamInputs(streamName + PUBLISH_URL_SUFFIX);
     }
 
@@ -69,7 +69,7 @@ public class KafkaStreamService {
      * @param streamName Stream name
      * @return
      */
-    public Map<String, LinkedHashMap<String, Object>> createStreamSubscribeInputs(String streamName) {
+    public Map<String, Map<String, Object>> createStreamSubscribeInputs(String streamName) {
         return createStreamInputs(streamName + SUBSCRIBE_URL_SUFFIX);
     }
 
@@ -81,7 +81,7 @@ public class KafkaStreamService {
      */
     public Map<String, KafkaStream> createAppPropertiesPublish(String streamName) {
 
-        LinkedHashMap<String, KafkaStream> kafkaStreamMap = new LinkedHashMap<>();
+        Map<String, KafkaStream> kafkaStreamMap = new LinkedHashMap<>();
         KafkaStream kafkaStream = createAppProperties(streamName, PUBLISH_URL_SUFFIX);
 
         kafkaStreamMap.put(streamName, kafkaStream);
@@ -97,7 +97,7 @@ public class KafkaStreamService {
      */
     public Map<String, KafkaStream> createAppPropertiesSubscribe(String streamName) {
 
-        LinkedHashMap<String, KafkaStream> kafkaStreamMap = new LinkedHashMap<>();
+        Map<String, KafkaStream> kafkaStreamMap = new LinkedHashMap<>();
         KafkaStream kafkaStream = createAppProperties(streamName, SUBSCRIBE_URL_SUFFIX);
 
         kafkaStreamMap.put(streamName, kafkaStream);
@@ -111,25 +111,25 @@ public class KafkaStreamService {
         return new KafkaStream(topicName);
     }
 
-    private Map<String, LinkedHashMap<String, Object>> createStreamInputs(String streamName) {
-        LinkedHashMap<String, LinkedHashMap<String, Object>> streamInputs = createBaseInputs();
-        LinkedHashMap<String, Object> stream =
+    private Map<String, Map<String, Object>> createStreamInputs(String streamName) {
+        Map<String, Map<String, Object>> streamInputs = createBaseInputs();
+        Map<String, Object> stream =
             blueprintHelperService.createStringInput(DEFAULT_STREAM_URL);
         streamInputs.put(streamName, stream);
         return streamInputs;
     }
 
-    private LinkedHashMap<String, LinkedHashMap<String, Object>> createBaseInputs() {
-        LinkedHashMap<String, LinkedHashMap<String, Object>> baseInputs = new LinkedHashMap<>();
+    private Map<String, Map<String, Object>> createBaseInputs() {
+        Map<String, Map<String, Object>> baseInputs = new LinkedHashMap<>();
 
-        LinkedHashMap<String, Object> kafka_message_router = blueprintHelperService
+        Map<String, Object> kafka_message_router = blueprintHelperService
             .createStringInput(DEFAULT_BOOTSTRAP_SERVER);
         baseInputs.put(KAFKA_INFO_BOOTSTRAP_SERVERS_INPUT_NAME, kafka_message_router);
 
-        LinkedHashMap<String, Object> kafka_username = blueprintHelperService.createStringInput(DEFAULT_AAF_USER);
+        Map<String, Object> kafka_username = blueprintHelperService.createStringInput(DEFAULT_AAF_USER);
         baseInputs.put(AFF_KAFKA_USER_INPUT_NAME, kafka_username);
 
-        LinkedHashMap<String, Object> kafka_password = blueprintHelperService.createStringInput(DEFAULT_AAF_PASSWORD);
+        Map<String, Object> kafka_password = blueprintHelperService.createStringInput(DEFAULT_AAF_PASSWORD);
         baseInputs.put(AAF_KAFKA_PASSWORD_INPUT_NAME, kafka_password);
 
         return baseInputs;