From: Marcin Migdal <marcin.migdal@nokia.com>
Date: Mon, 25 Mar 2019 12:25:06 +0000 (+0100)
Subject: Fix AAIProducer Task
X-Git-Tag: 1.2.2~19
X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=refs%2Fchanges%2F92%2F83192%2F2;p=dcaegen2%2Fservices%2Fprh.git

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 d0926e7a..998a9243 100644
--- 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 85b18b8a..c25528bd 100644
--- 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