diff options
Diffstat (limited to 'components/kpi-computation-ms/src/main')
2 files changed, 12 insertions, 5 deletions
diff --git a/components/kpi-computation-ms/src/main/java/org/onap/dcaegen2/kpi/controller/ConfigFetchFromCbs.java b/components/kpi-computation-ms/src/main/java/org/onap/dcaegen2/kpi/controller/ConfigFetchFromCbs.java index ba8e33ea..3ac0ef36 100644 --- a/components/kpi-computation-ms/src/main/java/org/onap/dcaegen2/kpi/controller/ConfigFetchFromCbs.java +++ b/components/kpi-computation-ms/src/main/java/org/onap/dcaegen2/kpi/controller/ConfigFetchFromCbs.java @@ -97,6 +97,8 @@ public class ConfigFetchFromCbs implements Runnable { if (jsonObject.getAsJsonObject("policies") != null) { JsonObject policyJson = jsonObject.getAsJsonObject("policies").getAsJsonArray("items").get(0) .getAsJsonObject().getAsJsonObject("config"); + log.info("policy json {}", policyJson); + Configuration.getInstance().updateConfigFromPolicy(policyJson); Map<String, Object> policy = new Gson().fromJson(policyJson, mapType); configPolicy.setConfig(policy); log.info("Config policy {}", configPolicy); diff --git a/components/kpi-computation-ms/src/main/java/org/onap/dcaegen2/kpi/models/Configuration.java b/components/kpi-computation-ms/src/main/java/org/onap/dcaegen2/kpi/models/Configuration.java index 930e631c..dbad3925 100644 --- a/components/kpi-computation-ms/src/main/java/org/onap/dcaegen2/kpi/models/Configuration.java +++ b/components/kpi-computation-ms/src/main/java/org/onap/dcaegen2/kpi/models/Configuration.java @@ -20,11 +20,6 @@ package org.onap.dcaegen2.kpi.models; -import com.google.gson.Gson; -import com.google.gson.JsonArray; -import com.google.gson.JsonObject; -import com.google.gson.reflect.TypeToken; - import java.lang.reflect.Type; import java.util.List; import java.util.Map; @@ -32,6 +27,11 @@ import java.util.Map; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import com.google.gson.Gson; +import com.google.gson.JsonArray; +import com.google.gson.JsonObject; +import com.google.gson.reflect.TypeToken; + /** * Model class for the application Configuration. */ @@ -259,6 +259,11 @@ public class Configuration { log.info("configuration from CBS {}", this); } + + public void updateConfigFromPolicy(JsonObject policyconfig) { + kpiConfig = policyconfig.toString(); + log.info("kpi config fetched from policy {}", kpiConfig); + } public String getKpiConfig() { return kpiConfig; |