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<TriggerEntity>	findTriggerByCorrelationId(String correlationId, org.springframework.data.domain.Pageable page)
List<TriggerEntity>	findTriggersLastPingAfter(OffsetDateTime dateTime)
Optional<TriggerEntity>	get(TriggerKey id)
boolean	hasPendingTriggers()	Checks if any job is still running or waiting for it's execution.
org.springframework.data.domain.Page<TriggerEntity>	listTriggers(TaskId<? extends Serializable> task, org.springframework.data.domain.Pageable page)
org.springframework.data.domain.Page<TriggerEntity>	listTriggers(TriggerKey key, TriggerStatus status, 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<TriggerEntity> get(TriggerKey id)

hasPendingTriggers

public boolean hasPendingTriggers()

Checks if any job is still running or waiting for it's execution.

findTriggersLastPingAfter

public List<TriggerEntity> findTriggersLastPingAfter(OffsetDateTime dateTime)

listTriggers

public org.springframework.data.domain.Page<TriggerEntity> listTriggers(@Nullable
 TriggerKey key,
 @Nullable
 TriggerStatus status,
 org.springframework.data.domain.Pageable page)

listTriggers

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

findTriggerByCorrelationId

public List<TriggerEntity> findTriggerByCorrelationId(String correlationId,
 org.springframework.data.domain.Pageable page)