Package org.sterl.spring.persistent_tasks.trigger

Class TriggerService

java.lang.Object

org.sterl.spring.persistent_tasks.trigger.TriggerService

@TransactionalService
public class TriggerService
extends Object

Constructor Summary

Constructors

Constructor	Description
TriggerService()

Method Summary

Modifier and Type	Method	Description
List<TriggerEntity>	cancel(Collection<TriggerKey> key)
Optional<TriggerEntity>	cancel(TriggerKey key)	If you changed your mind, cancel the persistentTask
long	countTriggers()
long	countTriggers(TaskId<?> taskId)	Counts the trigger using the name only from the TaskId
long	countTriggers(TriggerStatus status)
void	deleteAll()
org.springframework.data.domain.Page<TriggerEntity>	findAllTriggers(TaskId<?> task, org.springframework.data.domain.Pageable page)
org.springframework.data.domain.Page<TriggerEntity>	findAllTriggers(TriggerKey key, TriggerStatus status, org.springframework.data.domain.Pageable page)
List<TriggerEntity>	findTriggerByCorrelationId(String correlationId, org.springframework.data.domain.Pageable page)
Optional<TriggerEntity>	get(TriggerKey triggerKey)
boolean	hasPendingTriggers()	Checks if any job is still running or waiting for it's execution.
TriggerEntity	lockNextTrigger(String runOn)
List<TriggerEntity>	lockNextTrigger(String runOn, int count, OffsetDateTime timeDueAt)
int	markTriggersAsRunning(Collection<TriggerKey> keys, String runOn)
TriggerEntity	markTriggersAsRunning(TriggerEntity trigger, String runOn)
<T extends Serializable> TriggerEntity	queue(AddTriggerRequest<T> tigger)	Adds or updates an existing trigger based on its TriggerKey
List<TriggerEntity>	rescheduleAbandonedTasks(OffsetDateTime timeout)	Marks any tasks which are not on the given executors/schedulers abandoned for .
Optional<TriggerEntity>	run(AddTriggerRequest<?> request, String runningOn)
Optional<TriggerEntity>	run(TriggerKey triggerKey, String runningOn)	The main purpose of this method is to simplify testing and run just one trigger.
Optional<TriggerEntity>	run(TriggerEntity trigger)	Executes the given trigger directly in the current thread and handle any errors etc.
Optional<TriggerEntity>	updateRunAt(TriggerKey key, OffsetDateTime time)

Methods inherited from class java.lang.Object

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

Constructor Details

TriggerService

public TriggerService()

Method Details

run

@Transactional(propagation=NEVER)
public Optional<TriggerEntity> run(@Nullable
 TriggerEntity trigger)

Executes the given trigger directly in the current thread and handle any errors etc.

Parameters:

trigger - the TriggerEntity to run

Returns:

the reference to the found an executed TriggerEntity

run

@Transactional(propagation=NEVER)
public Optional<TriggerEntity> run(TriggerKey triggerKey,
 String runningOn)

The main purpose of this method is to simplify testing and run just one trigger.

Parameters:

triggerKey - the key to trigger which should be executed

runningOn - just any string, could be test for testing, usually the scheduler name

Returns:

the reference to the found an executed TriggerEntity

run

@Transactional(propagation=NEVER)
public Optional<TriggerEntity> run(@Nullable
 AddTriggerRequest<?> request,
 String runningOn)

markTriggersAsRunning

public TriggerEntity markTriggersAsRunning(TriggerEntity trigger,
 String runOn)

markTriggersAsRunning

public int markTriggersAsRunning(Collection<TriggerKey> keys,
 String runOn)

lockNextTrigger

public TriggerEntity lockNextTrigger(String runOn)

lockNextTrigger

public List<TriggerEntity> lockNextTrigger(String runOn,
 int count,
 OffsetDateTime timeDueAt)

get

public Optional<TriggerEntity> get(TriggerKey triggerKey)

findAllTriggers

@Transactional(readOnly=true,
               timeout=10)
public org.springframework.data.domain.Page<TriggerEntity> findAllTriggers(@Nullable
 TriggerKey key,
 @Nullable
 TriggerStatus status,
 org.springframework.data.domain.Pageable page)

findAllTriggers

@Transactional(readOnly=true,
               timeout=10)
public org.springframework.data.domain.Page<TriggerEntity> findAllTriggers(TaskId<?> task,
 org.springframework.data.domain.Pageable page)

deleteAll

public void deleteAll()

hasPendingTriggers

@Transactional(readOnly=true,
               timeout=5)
public boolean hasPendingTriggers()

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

queue

public <T extends Serializable> TriggerEntity queue(AddTriggerRequest<T> tigger)

Adds or updates an existing trigger based on its TriggerKey

Type Parameters:

T - the state type

Parameters:

tigger - the AddTriggerRequest to save

Returns:

the saved TriggerEntity

Throws:

IllegalStateException - if the trigger already exists and is TriggerStatus.RUNNING

cancel

public Optional<TriggerEntity> cancel(TriggerKey key)

If you changed your mind, cancel the persistentTask

cancel

public List<TriggerEntity> cancel(Collection<TriggerKey> key)

countTriggers

@Transactional(timeout=5,
               readOnly=true)
public long countTriggers(@Nullable
 TaskId<?> taskId)

Counts the trigger using the name only from the TaskId

Parameters:

taskId - to get the TaskId.name()

Returns:

the amount of stored tasks

countTriggers

public long countTriggers(@Nullable
 TriggerStatus status)

rescheduleAbandonedTasks

public List<TriggerEntity> rescheduleAbandonedTasks(OffsetDateTime timeout)

Marks any tasks which are not on the given executors/schedulers abandoned for . Retry will be triggered based on the set strategy.

countTriggers

public long countTriggers()

updateRunAt

public Optional<TriggerEntity> updateRunAt(TriggerKey key,
 OffsetDateTime time)

findTriggerByCorrelationId

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