X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=influxlogger%2Fsrc%2Fmain%2Fjava%2Forg%2Foran%2Fpmlog%2FInfluxStore.java;h=b25a4ca8528f69e61afbbaed8d005de8d9a08b76;hb=331535e4fea69fbdcf3c74cc1cdfe8b05c9080f4;hp=ba9f21ca830881f011e4763f6adfa1ba593bc21c;hpb=6dfbff6834c3a9da2d8f06b15eb94048cbad2d88;p=nonrtric%2Fplt%2Franpm.git diff --git a/influxlogger/src/main/java/org/oran/pmlog/InfluxStore.java b/influxlogger/src/main/java/org/oran/pmlog/InfluxStore.java index ba9f21c..b25a4ca 100644 --- a/influxlogger/src/main/java/org/oran/pmlog/InfluxStore.java +++ b/influxlogger/src/main/java/org/oran/pmlog/InfluxStore.java @@ -51,7 +51,6 @@ public class InfluxStore { @Getter private Disposable subscription; - private static com.google.gson.Gson gson = new com.google.gson.GsonBuilder().disableHtmlEscaping().create(); private final ApplicationConfig applConfig; private final InfluxDBClient influxClient; @@ -97,7 +96,7 @@ public class InfluxStore { this.subscription = input.flatMap(this::storeInInflux) // .subscribe(this::handleSentOk, // this::handleExceptionInStream, // - () -> stop()); + this::stop); } @@ -105,6 +104,7 @@ public class InfluxStore { return measInfoList.getMeasTypes().getMeasType(measResult.getP()); } + @SuppressWarnings("java:S1172") private void addCounterFieldToPoint(Point point, PmReport.MeasInfoList measInfoList, PmReport.MeasValuesList measValueList, PmReport.MeasResult measResult) { String measType = measType(measResult, measInfoList);