Package org.sterl.spring.persistent_tasks.trigger.component

Class ReadTriggerComponent

java.lang.Object
org.sterl.spring.persistent_tasks.trigger.component.ReadTriggerComponent
@TransactionalCompontant public class ReadTriggerComponent extends Object

  • Constructor Details

    • ReadTriggerComponent

      public ReadTriggerComponent()

  • Method Details

    • countByTaskName

      public long countByTaskName(@NotNull @NotNull String name)

    • countByStatus

      public long countByStatus(@Nullable TriggerStatus status)

    • get

      public Optional<RunningTriggerEntity> get(TriggerKey key)

    • hasPendingTriggers

      public boolean hasPendingTriggers()
      Checks if any job is still running or waiting for it's execution.

    • findTriggersLastPingAfter

      public List<RunningTriggerEntity> findTriggersLastPingAfter(OffsetDateTime dateTime)
      Searches for all triggers which are still running but the ping is long ago.
      Parameters:
      dateTime - the ping should be before this date
      Returns:
      all found triggers - never null

    • searchTriggers

      public org.springframework.data.domain.Page<RunningTriggerEntity> searchTriggers(@Nullable TriggerSearch search, org.springframework.data.domain.Pageable page)

    • searchGroupedTriggers

      public org.springframework.data.domain.Page<TriggerGroup> searchGroupedTriggers(@Nullable TriggerSearch search, org.springframework.data.domain.Pageable page)

    • listTriggers

      public org.springframework.data.domain.Page<RunningTriggerEntity> listTriggers(TaskId<? extends Serializable> task, org.springframework.data.domain.Pageable page)

    • findTriggersTimeoutOut

      public List<RunningTriggerEntity> findTriggersTimeoutOut(int max)