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=331535e4fea69fbdcf3c74cc1cdfe8b05c9080f4;hp=573b2c3b0aff20fd8b25c125a0c538744aa4edd9;hpb=9e3ded97088f197b335d060e1c9ddf7d6c0ecd89;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 573b2c3..ec6ddf3 100644 --- a/influxlogger/src/main/java/org/oran/pmlog/ConsumerRegstrationTask.java +++ b/influxlogger/src/main/java/org/oran/pmlog/ConsumerRegstrationTask.java @@ -26,8 +26,8 @@ import lombok.Getter; import org.oran.pmlog.clients.AsyncRestClient; import org.oran.pmlog.clients.AsyncRestClientFactory; -import org.oran.pmlog.clients.SecurityContext; import org.oran.pmlog.configuration.ApplicationConfig; +import org.oran.pmlog.oauth2.SecurityContext; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; @@ -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, //