X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Ftasks%2FRefreshConfigTask.java;h=4080b37cfd8b2c38c24f157b42db95403d6704c3;hb=842b9d220588fba7fc17df0cf9c094f91005118b;hp=f5834e35de2c2e4e568972bef956f9cd96f06be0;hpb=a538ca7e0b840e8dc20e85c1864697823ad96ae0;p=nonrtric.git diff --git a/policy-agent/src/main/java/org/oransc/policyagent/tasks/RefreshConfigTask.java b/policy-agent/src/main/java/org/oransc/policyagent/tasks/RefreshConfigTask.java index f5834e35..4080b37c 100644 --- a/policy-agent/src/main/java/org/oransc/policyagent/tasks/RefreshConfigTask.java +++ b/policy-agent/src/main/java/org/oransc/policyagent/tasks/RefreshConfigTask.java @@ -116,8 +116,9 @@ public class RefreshConfigTask { return cbsClient.updates(getConfigRequest, initialDelay, refreshPeriod); } - private Mono onErrorResume(Throwable trowable) { - logger.error("Could not refresh application configuration {}", trowable.toString()); + private Mono onErrorResume(Throwable throwable) { + String errMsg = throwable.toString(); + logger.error("Could not refresh application configuration. {}", errMsg); return Mono.empty(); } @@ -136,7 +137,7 @@ public class RefreshConfigTask { /** * Reads the configuration from file. */ - public void loadConfigurationFromFile() { + void loadConfigurationFromFile() { String filepath = appConfig.getLocalConfigurationFilePath(); if (filepath == null) { logger.debug("No localconfiguration file used"); @@ -147,9 +148,6 @@ public class RefreshConfigTask { try (InputStream inputStream = createInputStream(filepath)) { JsonObject rootObject = getJsonElement(inputStream).getAsJsonObject(); - if (rootObject == null) { - throw new JsonSyntaxException("Root is not a json object"); - } ApplicationConfigParser appParser = new ApplicationConfigParser(); appParser.parse(rootObject); appConfig.setConfiguration(appParser.getRicConfigs(), appParser.getDmaapPublisherConfig(),