X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=influxlogger%2Fsrc%2Fmain%2Fjava%2Forg%2Foran%2Fpmlog%2FConsumerRegstrationTask.java;h=ec6ddf3ac840c87f495526c518c124fc7b7273d4;hb=HEAD;hp=be16a20d187c53bfaa5ed60d5d1fe092b951e6cd;hpb=d806dbef4f43bb9c631c818e96c1a39e440c5e6c;p=nonrtric%2Fplt%2Franpm.git diff --git a/influxlogger/src/main/java/org/oran/pmlog/ConsumerRegstrationTask.java b/influxlogger/src/main/java/org/oran/pmlog/ConsumerRegstrationTask.java index be16a20..ec6ddf3 100644 --- a/influxlogger/src/main/java/org/oran/pmlog/ConsumerRegstrationTask.java +++ b/influxlogger/src/main/java/org/oran/pmlog/ConsumerRegstrationTask.java @@ -49,11 +49,6 @@ public class ConsumerRegstrationTask { private final AsyncRestClient restClient; private final ApplicationConfig applicationConfig; - private static com.google.gson.Gson gson = new com.google.gson.GsonBuilder() // - .disableHtmlEscaping() // - .excludeFieldsWithoutExposeAnnotation() // - .create(); - @Getter private boolean isRegisteredInIcs = false; @@ -74,7 +69,7 @@ public class ConsumerRegstrationTask { private void createSubscription() { putInfoJob() // .doOnError(this::handleRegistrationFailure) - .retryWhen(Retry.fixedDelay(100, Duration.ofMillis(5 * 1000))) // + .retryWhen(Retry.fixedDelay(100, Duration.ofMillis(5L * 1000))) // .subscribe( // null, // this::handleRegistrationFailure, //