X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=influxlogger%2Fsrc%2Ftest%2Fjava%2Forg%2Foran%2Fpmlog%2FApplicationTest.java;h=e8d69e688b2b15aff90c49c7ba4f83d05b5ec9e2;hb=HEAD;hp=da12e0afc1c4e8c854dd15c35290920a394fa67b;hpb=6dfbff6834c3a9da2d8f06b15eb94048cbad2d88;p=nonrtric%2Fplt%2Franpm.git

diff --git a/influxlogger/src/test/java/org/oran/pmlog/ApplicationTest.java b/influxlogger/src/test/java/org/oran/pmlog/ApplicationTest.java
index da12e0a..e8d69e6 100644
--- a/influxlogger/src/test/java/org/oran/pmlog/ApplicationTest.java
+++ b/influxlogger/src/test/java/org/oran/pmlog/ApplicationTest.java
@@ -21,7 +21,6 @@
 package org.oran.pmlog;
 
 import static org.assertj.core.api.Assertions.assertThat;
-import static org.awaitility.Awaitility.await;
 import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.Mockito.spy;
 
@@ -33,7 +32,6 @@ import java.lang.invoke.MethodHandles;
 import java.nio.charset.Charset;
 import java.nio.file.Files;
 import java.nio.file.Path;
-
 import org.json.JSONObject;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
@@ -43,11 +41,10 @@ import org.junit.jupiter.api.TestMethodOrder;
 import org.mockito.Mockito;
 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.configuration.ConsumerJobInfo;
 import org.oran.pmlog.configuration.WebClientConfig;
 import org.oran.pmlog.configuration.WebClientConfig.HttpProxyConfig;
+import org.oran.pmlog.oauth2.SecurityContext;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -174,15 +171,6 @@ class ApplicationTest {
         Mockito.verify(TestBeanFactory.influxStore, Mockito.times(1)).store(any(), any());
     }
 
-    @Test
-    void testJobCreation() throws Exception {
-        await().untilAsserted(() -> assertThat(consumerRegstrationTask.isRegisteredInIcs()).isTrue());
-        ConsumerJobInfo createdJob = this.icsSimulatorController.testResults.createdJob;
-        assertThat(createdJob).isNotNull();
-        assertThat(createdJob.jobDefinition.getDeliveryInfo().getTopic())
-                .isEqualTo(applicationConfig.getKafkaInputTopic());
-    }
-
     private AsyncRestClient restClient() {
         return restClient(false);
     }