diff options
author | Marcin Migdal <marcin.migdal@nokia.com> | 2019-03-25 13:25:06 +0100 |
---|---|---|
committer | Marcin Migdal <marcin.migdal@nokia.com> | 2019-03-25 13:34:48 +0100 |
commit | 7298679486cd1311f309a5dcbed528ef3c3c246b (patch) | |
tree | 5999af6d97c72da35967d54f7c1500b17f6e86b9 | |
parent | 8b0068a7fd94c656402f2ef85f5152a14760cb21 (diff) |
Fix AAIProducer Task
Change-Id: I3a82d44f760bb445c2a423591a22fe8d378e0d33
Issue-ID: DCAEGEN2-1361
Signed-off-by: Marcin Migdal <marcin.migdal@nokia.com>
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 |