summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authormicdzied <michal.1.dziedzic@nokia.com>2019-06-05 14:09:42 +0200
committermicdzied <michal.1.dziedzic@nokia.com>2019-06-05 14:09:42 +0200
commitc00bb15ad7c2741bd4d87506f2e3e4d455e01514 (patch)
tree951711cc3622b82b5ed4308cbcb4be310f053c3e
parent7c8f795a243d1b68c5f1595933aa564b513a23fd (diff)
fix logging
Change-Id: Iebc973500f880f6b5c248b5e26740568ac993b0b Issue-ID: DCAEGEN2-1601 Signed-off-by: micdzied <michal.1.dziedzic@nokia.com>
-rw-r--r--prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasks.java15
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);
}
}