diff options
Diffstat (limited to 'src/main/java/org/onap/dcae/commonFunction/DmaapPropertyReader.java')
-rw-r--r-- | src/main/java/org/onap/dcae/commonFunction/DmaapPropertyReader.java | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/src/main/java/org/onap/dcae/commonFunction/DmaapPropertyReader.java b/src/main/java/org/onap/dcae/commonFunction/DmaapPropertyReader.java index b10f5882..6ff24abf 100644 --- a/src/main/java/org/onap/dcae/commonFunction/DmaapPropertyReader.java +++ b/src/main/java/org/onap/dcae/commonFunction/DmaapPropertyReader.java @@ -52,7 +52,8 @@ public class DmaapPropertyReader { fr = new FileReader(CambriaConfigFile); root = new JsonParser().parse(fr); - //Check if dmaap config is handled by legacy controller/service manager + // Check if dmaap config is handled by legacy controller/service + // manager if (root.getAsJsonObject().has("channels")) { JsonArray jsonObject = (JsonArray) root.getAsJsonObject().get("channels"); @@ -88,13 +89,14 @@ public class DmaapPropertyReader { } } else { - //Handing new format from controllergen2/config_binding_service + // Handing new format from controllergen2/config_binding_service JsonObject jsonObject = root.getAsJsonObject(); Set<Map.Entry<String, JsonElement>> entries = jsonObject.entrySet(); for (Map.Entry<String, JsonElement> entry : entries) { - - JsonElement topicurl = entry.getValue().getAsJsonObject().get("dmaap_info").getAsJsonObject().get("topic_url"); + + JsonElement topicurl = entry.getValue().getAsJsonObject().get("dmaap_info").getAsJsonObject() + .get("topic_url"); String[] urlParts = dmaapUrlSplit(topicurl.toString().replace("\"", "")); String mrTopic = null; |