Package org.sterl.spring.persistent_tasks.scheduler

Class SchedulerService

java.lang.Object
org.sterl.spring.persistent_tasks.scheduler.SchedulerService
public class SchedulerService extends Object
Use this service if direct access to the Scheduler is required.
Note: This Service is optional, as it could be disabled if no background tasks should be execute on this note. As so the TriggerService should be preferred to queue tasks.

  • Constructor Details

    • SchedulerService

      public SchedulerService()

  • Method Details

    • start

      @PostConstruct public void start()

    • setMaxThreads

      public void setMaxThreads(int value)

    • stop

      @PreDestroy public void stop()

    • shutdownNow

      public void shutdownNow()

    • getScheduler

      public SchedulerEntity getScheduler()

    • findStatus

      public Optional<SchedulerEntity> findStatus(String name)

    • triggerNextTasks

      @NonNull public List<Future<TriggerKey>> triggerNextTasks()
      Simply triggers the next persistentTask which is now due to be executed

    • triggerNextTasks

      @Transactional(propagation=NEVER) @NonNull public List<Future<TriggerKey>> triggerNextTasks(OffsetDateTime timeDue)
      Like triggerNextTasks() but allows to set the time e.g. to the future to trigger tasks which wouldn't be triggered now.

      This method should not be called in a transaction!

    • runOrQueue

      @Transactional(timeout=10) public <T extends Serializable> TriggerKey runOrQueue(AddTriggerRequest<T> triggerRequest)
      Runs the given trigger if a free threads are available and the runAt time is not in the future.
      Returns:
      the reference to the Future with the key, if no threads are available it is resolved

    • checkIfTriggerShouldRun

      @TransactionalEventListener(phase=AFTER_COMMIT) public void checkIfTriggerShouldRun(TriggerAddedEvent addedTrigger)

    • getStatus

      public SchedulerEntity getStatus()

    • rescheduleAbandonedTasks

      @Transactional public List<TriggerEntity> rescheduleAbandonedTasks(OffsetDateTime timeout)

    • listAll

      public List<SchedulerEntity> listAll()

    • getRunning

      public Collection<Future<TriggerKey>> getRunning()

    • getRunningTriggers

      public List<TriggerEntity> getRunningTriggers()

    • hasRunningTriggers

      public boolean hasRunningTriggers()