diff options
| -rw-r--r-- | vid-app-common/src/main/java/org/onap/vid/job/impl/JobSchedulerInitializer.java | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/vid-app-common/src/main/java/org/onap/vid/job/impl/JobSchedulerInitializer.java b/vid-app-common/src/main/java/org/onap/vid/job/impl/JobSchedulerInitializer.java index b3ab75b23..b5c2dd74b 100644 --- a/vid-app-common/src/main/java/org/onap/vid/job/impl/JobSchedulerInitializer.java +++ b/vid-app-common/src/main/java/org/onap/vid/job/impl/JobSchedulerInitializer.java @@ -46,6 +46,14 @@ public class JobSchedulerInitializer { private FeatureManager featureManager; private JobCommandFactory jobCommandFactory; private EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(JobSchedulerInitializer.class); + public static final List<Job.JobStatus> WORKERS_TOPICS = ImmutableList.of( + Job.JobStatus.PENDING, + Job.JobStatus.CREATING, + Job.JobStatus.IN_PROGRESS, + Job.JobStatus.RESOURCE_IN_PROGRESS, + Job.JobStatus.PENDING_RESOURCE + ); + @Autowired public JobSchedulerInitializer( @@ -61,14 +69,6 @@ public class JobSchedulerInitializer { } - public static final List<Job.JobStatus> WORKERS_TOPICS = ImmutableList.of( - Job.JobStatus.PENDING, - Job.JobStatus.CREATING, - Job.JobStatus.IN_PROGRESS, - Job.JobStatus.RESOURCE_IN_PROGRESS, - Job.JobStatus.PENDING_RESOURCE - ); - @PostConstruct public void init() { WORKERS_TOPICS.forEach(topic->scheduleJobWorker(topic, 1)); |