From: micdzied <michal.1.dziedzic@nokia.com>
Date: Wed, 5 Jun 2019 12:09:42 +0000 (+0200)
Subject: fix logging
X-Git-Tag: 1.3.1~28^2
X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=refs%2Fchanges%2F61%2F89361%2F1;p=dcaegen2%2Fservices%2Fprh.git

fix logging

Change-Id: Iebc973500f880f6b5c248b5e26740568ac993b0b
Issue-ID: DCAEGEN2-1601
Signed-off-by: micdzied <michal.1.dziedzic@nokia.com>
---

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<State> 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<MessageRouterPublishResponse>
-    publishToDmaapConfiguration(final State state) {
+    private Flux<MessageRouterPublishResponse> 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);
         }
     }