From 7298679486cd1311f309a5dcbed528ef3c3c246b Mon Sep 17 00:00:00 2001 From: Marcin Migdal Date: Mon, 25 Mar 2019 13:25:06 +0100 Subject: Fix AAIProducer Task Change-Id: I3a82d44f760bb445c2a423591a22fe8d378e0d33 Issue-ID: DCAEGEN2-1361 Signed-off-by: Marcin Migdal --- .../org/onap/dcaegen2/services/prh/tasks/AaiProducerTaskImpl.java | 2 +- .../onap/dcaegen2/services/prh/tasks/DmaapPublisherTaskImpl.java | 6 +++--- 2 files changed, 4 insertions(+), 4 deletions(-) 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 -- cgit 1.2.3-korg