Added support for using oauth token for Kafka

[nonrtric/plt/ranpm.git] / pmproducer / src / test / java / org / oran / pmproducer / IntegrationWithIcs.java

diff --git a/pmproducer/src/test/java/org/oran/pmproducer/IntegrationWithIcs.java b/pmproducer/src/test/java/org/oran/pmproducer/IntegrationWithIcs.java
index e7875e2..de79b60 100644 (file)
--- a/pmproducer/src/test/java/org/oran/pmproducer/IntegrationWithIcs.java
+++ b/pmproducer/src/test/java/org/oran/pmproducer/IntegrationWithIcs.java
@@ -30,11 +30,11 @@ import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.Test;
 import org.oran.pmproducer.clients.AsyncRestClient;
 import org.oran.pmproducer.clients.AsyncRestClientFactory;
-import org.oran.pmproducer.clients.SecurityContext;
 import org.oran.pmproducer.configuration.ApplicationConfig;
 import org.oran.pmproducer.configuration.WebClientConfig;
 import org.oran.pmproducer.configuration.WebClientConfig.HttpProxyConfig;
 import org.oran.pmproducer.filter.PmReportFilter;
+import org.oran.pmproducer.oauth2.SecurityContext;
 import org.oran.pmproducer.r1.ConsumerJobInfo;
 import org.oran.pmproducer.repository.Jobs;
 import org.oran.pmproducer.tasks.ProducerRegstrationTask;
@@ -83,11 +83,6 @@ class IntegrationWithIcs {
             return "https://localhost:8434";
         }
 
-        @Override
-        public String getDmaapBaseUrl() {
-            return thisProcessUrl();
-        }
-
         @Override
         public String getSelfUrl() {
             return thisProcessUrl();