Fix AAIProducer Task

Change-Id: I3a82d44f760bb445c2a423591a22fe8d378e0d33
Issue-ID: DCAEGEN2-1361
Signed-off-by: Marcin Migdal <marcin.migdal@nokia.com>

diff --git a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/AaiProducerTaskImpl.java b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/AaiProducerTaskImpl.java
index d0926e7..998a924 100644 (file)
--- a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/AaiProducerTaskImpl.java
+++ b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/AaiProducerTaskImpl.java
@@ -70,7 +70,7 @@ public class AaiProducerTaskImpl extends AaiProducerTask {
     @Override
     AaiHttpPatchClient resolveClient() {
         return new AaiHttpPatchClient(resolveConfiguration(),
-                new AaiJsonBodyBuilderImpl(), new CloudHttpClient());
+                new AaiJsonBodyBuilderImpl(), new AaiHttpClientFactory(resolveConfiguration()).build());
     }
 
     @Override

diff --git a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapPublisherTaskImpl.java b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapPublisherTaskImpl.java
index 85b18b8..c25528b 100644 (file)
--- a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapPublisherTaskImpl.java
+++ b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapPublisherTaskImpl.java
@@ -46,7 +46,7 @@ import reactor.core.publisher.Mono;
 public class DmaapPublisherTaskImpl implements DmaapPublisherTask {
 
     private static final Logger LOGGER = LoggerFactory.getLogger(DmaapPublisherTaskImpl.class);
-    private DmaapPublisherConfiguration dmaapPublisherConfiguration;
+    private Config config;
 
     private final PublisherReactiveHttpClientFactory httpClientFactory;
 
@@ -56,7 +56,7 @@ public class DmaapPublisherTaskImpl implements DmaapPublisherTask {
     }
 
     DmaapPublisherTaskImpl(Config config, PublisherReactiveHttpClientFactory httpClientFactory) {
-        this.dmaapPublisherConfiguration = config.getDmaapPublisherConfiguration();
+        this.config = config;
         this.httpClientFactory = httpClientFactory;
     }
 
@@ -72,7 +72,7 @@ public class DmaapPublisherTaskImpl implements DmaapPublisherTask {
 
     @Override
     public DMaaPPublisherReactiveHttpClient resolveClient() throws SSLException{
-            return httpClientFactory.create(dmaapPublisherConfiguration);
+            return httpClientFactory.create(config.getDmaapPublisherConfiguration());
 
     }
 }
\ No newline at end of file