From c00bb15ad7c2741bd4d87506f2e3e4d455e01514 Mon Sep 17 00:00:00 2001 From: micdzied Date: Wed, 5 Jun 2019 14:09:42 +0200 Subject: fix logging Change-Id: Iebc973500f880f6b5c248b5e26740568ac993b0b Issue-ID: DCAEGEN2-1601 Signed-off-by: micdzied --- .../onap/dcaegen2/services/prh/tasks/ScheduledTasks.java | 15 +++------------ 1 file changed, 3 insertions(+), 12 deletions(-) diff --git a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasks.java b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasks.java index 5d438e37..670d2140 100644 --- a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasks.java +++ b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasks.java @@ -113,15 +113,8 @@ public class ScheduledTasks { ) .flatMap(this::queryAaiForConfiguration) .flatMap(this::publishToAaiConfiguration) - .doOnError(exception -> - LOGGER.warn("AAIProducerTask exception has been registered: ", exception)) - .onErrorResume(resumePrhPredicate(), exception -> Mono.empty()) .flatMap(this::processAdditionalFields) - .doOnError(exception -> - LOGGER.warn("BBSActionsTask exception has been registered: ", exception)) .flatMap(this::publishToDmaapConfiguration) - .doOnError(exception -> - LOGGER.warn("DMaaPProducerTask exception has been registered: ", exception)) .onErrorResume(resumePrhPredicate(), exception -> Mono.empty()) .doOnTerminate(mainCountDownLatch::countDown) .subscribe(this::onSuccess, this::onError, this::onComplete); @@ -175,6 +168,7 @@ public class ScheduledTasks { .execute(state.dmaapModel) .map(x -> state); } catch (PrhTaskException | SSLException e) { + LOGGER.warn("AAIProducerTask exception has been registered: ", e); return Mono.error(e); } } @@ -182,23 +176,20 @@ public class ScheduledTasks { private Mono processAdditionalFields(final State state) { if (state.activationStatus) { LOGGER.debug("Re-registration - Logical links won't be updated."); - return Mono.just(state); } - return bbsActionsTask.execute(state.dmaapModel).map(x -> state); } - private Flux - publishToDmaapConfiguration(final State state) { + private Flux publishToDmaapConfiguration(final State state) { try { if (state.activationStatus) { LOGGER.debug("Re-registration - Using PNF_UPDATE DMaaP topic."); return dmaapUpdateProducerTask.execute(state.dmaapModel); } - return dmaapReadyProducerTask.execute(state.dmaapModel); } catch (PrhTaskException e) { + LOGGER.warn("DMaaPProducerTask exception has been registered: ", e); return Flux.error(e); } } -- cgit 1.2.3-korg