summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorMarcin Migdal <marcin.migdal@nokia.com>2019-03-25 13:25:06 +0100
committerMarcin Migdal <marcin.migdal@nokia.com>2019-03-25 13:34:48 +0100
commit7298679486cd1311f309a5dcbed528ef3c3c246b (patch)
tree5999af6d97c72da35967d54f7c1500b17f6e86b9
parent8b0068a7fd94c656402f2ef85f5152a14760cb21 (diff)
Fix AAIProducer Task
Change-Id: I3a82d44f760bb445c2a423591a22fe8d378e0d33 Issue-ID: DCAEGEN2-1361 Signed-off-by: Marcin Migdal <marcin.migdal@nokia.com>
-rw-r--r--prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/AaiProducerTaskImpl.java2
-rw-r--r--prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/DmaapPublisherTaskImpl.java6
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