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 Summary

Constructors

Constructor	Description
ReadTriggerComponent()

Method Summary

Modifier and Type	Method	Description
long	countByStatus(TriggerStatus status)
long	countByTaskName(@NotNull String name)
List<RunningTriggerEntity>	findTriggersLastPingAfter(OffsetDateTime dateTime)
List<RunningTriggerEntity>	findTriggersTimeoutOut(int max)
Optional<RunningTriggerEntity>	get(TriggerKey key)
boolean	hasPendingTriggers()	Checks if any job is still running or waiting for it's execution.
org.springframework.data.domain.Page<RunningTriggerEntity>	listTriggers(TaskId<? extends Serializable> task, org.springframework.data.domain.Pageable page)
org.springframework.data.domain.Page<RunningTriggerEntity>	searchTriggers(TriggerSearch search, org.springframework.data.domain.Pageable page)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)

searchTriggers

public org.springframework.data.domain.Page<RunningTriggerEntity> searchTriggers(@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)