Improve Test coverage of InfluxLogger

[nonrtric/plt/ranpm.git] / influxlogger / src / main / java / org / oran / pmlog / ConsumerRegstrationTask.java

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 (file)
--- 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, //