fix logging

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

1 files 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<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);
         }
     }