summaryrefslogtreecommitdiffstats
path: root/prh-app-server/src
diff options
context:
space:
mode:
Diffstat (limited to 'prh-app-server/src')
-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);
}
}