summaryrefslogtreecommitdiffstats
path: root/prh-app-server/src/main/java/org/onap
diff options
context:
space:
mode:
authorJoanna Jeremicz <joanna.jeremicz@nokia.com>2019-11-04 12:14:22 +0100
committerJoanna Jeremicz <joanna.jeremicz@nokia.com>2019-11-05 10:43:17 +0100
commit0f0892fbf3105c1dfa695bc380fc525b82fa9d86 (patch)
treee98bd57b49280f3a784001c489c86e78263f586c /prh-app-server/src/main/java/org/onap
parent30101b0ba9a5416d66d7290ec73f3d4acb383772 (diff)
Update PNF in AAI
PNF is now updated with parameters from VES event whenever PNF_UPDATE case is executed Issue-ID: DCAEGEN2-1911 Change-Id: I262e4fbf52c92f7a187f3730b40f7f5d689d2dc3 Signed-off-by: Joanna Jeremicz <joanna.jeremicz@nokia.com>
Diffstat (limited to 'prh-app-server/src/main/java/org/onap')
-rw-r--r--prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasks.java4
-rw-r--r--prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasksRunner.java2
2 files changed, 3 insertions, 3 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 74c6c426..0d268003 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
@@ -161,9 +161,7 @@ public class ScheduledTasks {
private Mono<State> publishToAaiConfiguration(final State state) {
try {
- return state.activationStatus
- ? Mono.just(state)
- : aaiProducerTask
+ return aaiProducerTask
.execute(state.dmaapModel)
.map(x -> state);
} catch (PrhTaskException e) {
diff --git a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasksRunner.java b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasksRunner.java
index 25ed262e..9e432546 100644
--- a/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasksRunner.java
+++ b/prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasksRunner.java
@@ -25,6 +25,7 @@ import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ScheduledFuture;
+import javax.annotation.PreDestroy;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.slf4j.Marker;
@@ -63,6 +64,7 @@ public class ScheduledTasksRunner {
/**
* Function which have to stop tasks execution.
*/
+ @PreDestroy
public synchronized void cancelTasks() {
scheduledPrhTaskFutureList.forEach(x -> x.cancel(false));
scheduledPrhTaskFutureList.clear();