X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Fconfiguration%2FApplicationConfigParser.java;h=5495710782a5766b9661fc2fbaa05b56105c8d7a;hb=5e3c4449140ece8dde2502d04f6ac476a5ca6c89;hp=ea6605375d8597f1f2caf322c230ef45c1988950;hpb=672fe20c9ed06da97ee530d76f1492ab5aa7bad9;p=nonrtric.git diff --git a/policy-agent/src/main/java/org/oransc/policyagent/configuration/ApplicationConfigParser.java b/policy-agent/src/main/java/org/oransc/policyagent/configuration/ApplicationConfigParser.java index ea660537..54957107 100644 --- a/policy-agent/src/main/java/org/oransc/policyagent/configuration/ApplicationConfigParser.java +++ b/policy-agent/src/main/java/org/oransc/policyagent/configuration/ApplicationConfigParser.java @@ -70,8 +70,6 @@ public class ApplicationConfigParser { Properties dmaapConsumerConfig = new Properties(); JsonObject agentConfigJson = root.getAsJsonObject(CONFIG); - List ricConfigs = parseRics(agentConfigJson); - Map controllerConfigs = parseControllerConfigs(agentConfigJson); JsonObject json = agentConfigJson.getAsJsonObject("streams_publishes"); if (json != null) { @@ -83,6 +81,8 @@ public class ApplicationConfigParser { dmaapConsumerConfig = parseDmaapConfig(json); } + List ricConfigs = parseRics(agentConfigJson); + Map controllerConfigs = parseControllerConfigs(agentConfigJson); checkConfigurationConsistency(ricConfigs, controllerConfigs); return ImmutableConfigParserResult.builder() // @@ -205,8 +205,8 @@ public class ApplicationConfigParser { dmaapProps.put("group", path.consumerGroup); dmaapProps.put("id", path.consumerId); dmaapProps.put("TransportType", ProtocolTypeConstants.HTTPNOAUTH.toString()); - dmaapProps.put("timeout", 15000); - dmaapProps.put("limit", 100); + dmaapProps.put("timeout", "15000"); + dmaapProps.put("limit", "100"); dmaapProps.put("maxBatchSize", "10"); dmaapProps.put("maxAgeMs", "10000"); dmaapProps.put("compress", true);