aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorgrabinsk <maciej.grabinski@nokia.com>2019-06-14 13:50:16 +0200
committergrabinsk <maciej.grabinski@nokia.com>2019-06-14 13:50:16 +0200
commitb494ec44ddd26a516e36d69cbbf06f1214d37825 (patch)
tree19254c557c9ce29d69bb3da71446f6a9666c2d58
parent4117c9fd7fcea895e18872e0d541e0f14a9a41b9 (diff)
Do not start scheduling until application starts
(moving task schedule starting logic from bean's post construct to ApplicationStartedEvent listener) Change-Id: Ia09ecbf5efda9b8f838053359bba2cfe80ce095b Issue-ID: DCAEGEN2-1544 Signed-off-by: grabinsk <maciej.grabinski@nokia.com>
-rw-r--r--prh-app-server/src/main/java/org/onap/dcaegen2/services/prh/tasks/ScheduledTasksRunner.java9
1 files changed, 7 insertions, 2 deletions
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 c3eaa12f..25ed262e 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
@@ -24,13 +24,14 @@ import java.time.Duration;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ScheduledFuture;
-import javax.annotation.PostConstruct;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.slf4j.Marker;
import org.slf4j.MarkerFactory;
+import org.springframework.boot.context.event.ApplicationStartedEvent;
import org.springframework.context.annotation.Configuration;
+import org.springframework.context.event.EventListener;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.scheduling.annotation.EnableScheduling;
@@ -54,6 +55,11 @@ public class ScheduledTasksRunner {
this.scheduledTask = scheduledTask;
}
+ @EventListener
+ public void onApplicationStartedEvent(ApplicationStartedEvent applicationStartedEvent) {
+ tryToStartTask();
+ }
+
/**
* Function which have to stop tasks execution.
*/
@@ -67,7 +73,6 @@ public class ScheduledTasksRunner {
*
* @return status of operation execution: true - started, false - not started
*/
- @PostConstruct
public synchronized boolean tryToStartTask() {
LOGGER.info(ENTRY, "Start scheduling PRH workflow");
if (scheduledPrhTaskFutureList.isEmpty()) {