diff options
Diffstat (limited to 'components/bbs-event-processor/src/main/java/org/onap/bbs/event/processor/tasks/DmaapReRegistrationConsumerTaskImpl.java')
-rw-r--r-- | components/bbs-event-processor/src/main/java/org/onap/bbs/event/processor/tasks/DmaapReRegistrationConsumerTaskImpl.java | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/components/bbs-event-processor/src/main/java/org/onap/bbs/event/processor/tasks/DmaapReRegistrationConsumerTaskImpl.java b/components/bbs-event-processor/src/main/java/org/onap/bbs/event/processor/tasks/DmaapReRegistrationConsumerTaskImpl.java index 92f5a86f..e40037b1 100644 --- a/components/bbs-event-processor/src/main/java/org/onap/bbs/event/processor/tasks/DmaapReRegistrationConsumerTaskImpl.java +++ b/components/bbs-event-processor/src/main/java/org/onap/bbs/event/processor/tasks/DmaapReRegistrationConsumerTaskImpl.java @@ -20,6 +20,10 @@ package org.onap.bbs.event.processor.tasks; +import com.google.gson.JsonElement; + +import java.util.Optional; + import javax.annotation.PostConstruct; import javax.annotation.PreDestroy; import javax.net.ssl.SSLException; @@ -85,6 +89,8 @@ public class DmaapReRegistrationConsumerTaskImpl implements DmaapReRegistrationC public synchronized void updateConfiguration() { try { LOGGER.info("DMaaP PNF reregistration consumer update due to new application configuration"); + LOGGER.info("Creating secure context with:\n {}", + this.configuration.getDmaapReRegistrationConsumerConfiguration()); httpClient = httpClientFactory.create(this.configuration.getDmaapReRegistrationConsumerConfiguration()); } catch (SSLException e) { LOGGER.error("SSL error while updating HTTP Client after a config update"); @@ -96,7 +102,7 @@ public class DmaapReRegistrationConsumerTaskImpl implements DmaapReRegistrationC public Flux<ReRegistrationConsumerDmaapModel> execute(String taskName) { LOGGER.debug("Executing task for Re-Registration with name \"{}\"", taskName); DMaaPConsumerReactiveHttpClient httpClient = getHttpClient(); - Mono<String> response = httpClient.getDMaaPConsumerResponse(); + Mono<JsonElement> response = httpClient.getDMaaPConsumerResponse(Optional.empty()); return reRegistrationDmaapConsumerJsonParser.extractModelFromDmaap(response) .switchIfEmpty(Flux.error(EMPTY_DMAAP_EXCEPTION)) .doOnError(e -> { |