X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=pmproducer%2Fsrc%2Fmain%2Fjava%2Forg%2Foran%2Fpmproducer%2Frepository%2FJobs.java;fp=pmproducer%2Fsrc%2Fmain%2Fjava%2Forg%2Foran%2Fpmproducer%2Frepository%2FJobs.java;h=2b48b6200f7f34f2f256a57b7632b9cdd5a4b1d4;hb=54c8fecebbb5e19010e56eddf3aba8e127e0abc3;hp=5b257bfc5bd6cb9363c24583f6ea245177e5d85c;hpb=b4e189aa552b860f82c548331d5acd34c7262a53;p=nonrtric%2Fplt%2Franpm.git

diff --git a/pmproducer/src/main/java/org/oran/pmproducer/repository/Jobs.java b/pmproducer/src/main/java/org/oran/pmproducer/repository/Jobs.java
index 5b257bf..2b48b62 100644
--- a/pmproducer/src/main/java/org/oran/pmproducer/repository/Jobs.java
+++ b/pmproducer/src/main/java/org/oran/pmproducer/repository/Jobs.java
@@ -29,13 +29,12 @@ import java.util.Vector;
 
 import lombok.Getter;
 
-import org.oran.pmproducer.clients.AsyncRestClientFactory;
-import org.oran.pmproducer.clients.SecurityContext;
 import org.oran.pmproducer.configuration.ApplicationConfig;
 import org.oran.pmproducer.exceptions.ServiceException;
 import org.oran.pmproducer.filter.FilterFactory;
 import org.oran.pmproducer.filter.FilteredData;
 import org.oran.pmproducer.filter.PmReportFilter;
+import org.oran.pmproducer.oauth2.SecurityContext;
 import org.oran.pmproducer.repository.Job.Parameters;
 import org.oran.pmproducer.repository.Job.Parameters.KafkaDeliveryInfo;
 import org.oran.pmproducer.tasks.TopicListener.DataFromTopic;
@@ -117,13 +116,11 @@ public class Jobs {
     private Map<String, Job> allJobs = new HashMap<>();
     private MultiMap<Job> jobsByType = new MultiMap<>();
     private Map<String, JobGroup> jobGroups = new HashMap<>(); // Key is Topic
-    private final AsyncRestClientFactory restclientFactory;
     private final List<Observer> observers = new ArrayList<>();
     private final ApplicationConfig appConfig;
 
     public Jobs(@Autowired ApplicationConfig applicationConfig, @Autowired SecurityContext securityContext,
             @Autowired ApplicationConfig appConfig) {
-        restclientFactory = new AsyncRestClientFactory(applicationConfig.getWebClientConfig(), securityContext);
         this.appConfig = appConfig;
     }