diff options
Diffstat (limited to 'mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/dmaap/StreamsService.java')
-rw-r--r-- | mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/dmaap/StreamsService.java | 34 |
1 files changed, 22 insertions, 12 deletions
diff --git a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/dmaap/StreamsService.java b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/dmaap/StreamsService.java index 16687fc..051b060 100644 --- a/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/dmaap/StreamsService.java +++ b/mod/bpgenerator/onap/src/main/java/org/onap/blueprintgenerator/service/dmaap/StreamsService.java @@ -35,21 +35,33 @@ import java.util.Map; /** * @author : Ravi Mantena - * @date 10/16/2020 - * Application: ONAP - Blueprint Generator - * Service to create Streams + * @date 10/16/2020 Application: ONAP - Blueprint Generator Service to create Streams */ - - @Service public class StreamsService { @Autowired private BlueprintHelperService blueprintHelperService; - //Methos to create streams for Dmaap Blueprint - public Map<String, Object> createStreams(Map<String, LinkedHashMap<String, Object>> inputs, String name, String type, String key, String route, char o){ - Map<String,Object> response = new HashMap<>(); + /** + * Creates streams for Dmaap Blueprint + * + * @param inputs Inputs + * @param name Name + * @param type Type + * @param key Key + * @param route Route + * @param o For Data Router Type s + * @return + */ + public Map<String, Object> createStreams( + Map<String, LinkedHashMap<String, Object>> inputs, + String name, + String type, + String key, + String route, + char o) { + Map<String, Object> response = new HashMap<>(); Streams streams = new Streams(); LinkedHashMap<String, Object> stringType = new LinkedHashMap(); @@ -63,8 +75,8 @@ public class StreamsService { inputs.put(key + "_" + name + "_location", stringType); streams.setLocation(location); - if(blueprintHelperService.isDataRouterType(type)) { - if('s' == o) { + if (blueprintHelperService.isDataRouterType(type)) { + if ('s' == o) { GetInput username = new GetInput(); username.setBpInputName(key + "_" + name + "_username"); streams.setUsername(username); @@ -89,7 +101,6 @@ public class StreamsService { streams.setScheme("https"); } - } else { GetInput client = new GetInput(); client.setBpInputName(key + "_" + name + "_client_role"); @@ -100,5 +111,4 @@ public class StreamsService { response.put("inputs", inputs); return response; } - } |