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

Class EditTriggerComponent

java.lang.Object

org.sterl.spring.persistent_tasks.trigger.component.EditTriggerComponent

@Component
@Transactional(timeout=30)
public class EditTriggerComponent
extends Object

Constructor Summary

Constructors

Constructor	Description
EditTriggerComponent()

Method Summary

Modifier and Type	Method	Description
<T extends Serializable> RunningTriggerEntity	addTrigger(TriggerRequest<T> tigger)
<T extends Serializable> @NonNull List<RunningTriggerEntity>	addTriggers(Collection<TriggerRequest<T>> newTriggers)
Optional<RunningTriggerEntity>	cancelTask(TriggerKey id, Exception e)
Optional<RunningTriggerEntity>	completeTaskWithSuccess(TriggerKey key, Serializable state)
void	deleteAll()
void	deleteTrigger(RunningTriggerEntity trigger)
RunningTriggerEntity	expireTrigger(RunningTriggerEntity t, Serializable state, Exception e)	Expires a trigger which was waiting for a signal that never arrived.
Optional<RunningTriggerEntity>	failTrigger(TriggerKey key, Serializable state, Exception e, OffsetDateTime retryAt)	Sets error based on the fact if an exception is given or not.
int	markTriggersAsRunning(Collection<TriggerKey> keys, String runOn)
org.springframework.data.domain.Page<RunningTriggerEntity>	resume(TriggerRequest<?> trigger)
<T extends Serializable> Optional<RunningTriggerEntity>	resumeOne(TriggerSearch search, Function<T,T> stateModifier)	Resumes the first found trigger with the given
void	triggerIsNowRunning(RunningTriggerEntity trigger, Serializable state)

Methods inherited from class java.lang.Object

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

Constructor Details

EditTriggerComponent

public EditTriggerComponent()

Method Details

completeTaskWithSuccess

public Optional<RunningTriggerEntity> completeTaskWithSuccess(TriggerKey key,
 Serializable state)

failTrigger

public Optional<RunningTriggerEntity> failTrigger(TriggerKey key,
 Serializable state,
 Exception e,
 OffsetDateTime retryAt)

Sets error based on the fact if an exception is given or not.

cancelTask

public Optional<RunningTriggerEntity> cancelTask(TriggerKey id,
 Exception e)

addTrigger

public <T extends Serializable>
RunningTriggerEntity addTrigger(TriggerRequest<T> tigger)

resume

public org.springframework.data.domain.Page<RunningTriggerEntity> resume(TriggerRequest<?> trigger)

resumeOne

public <T extends Serializable>
Optional<RunningTriggerEntity> resumeOne(TriggerSearch search,
 Function<T,T> stateModifier)

Resumes the first found trigger with the given

Type Parameters:

T - state type

Parameters:

search - search to run

stateModifier - updates the state and should return the run

Returns:

the updated trigger

expireTrigger

public RunningTriggerEntity expireTrigger(RunningTriggerEntity t,
 Serializable state,
 Exception e)

Expires a trigger which was waiting for a signal that never arrived. This is a terminal end state: the trigger is finished with status TriggerStatus.EXPIRED_SIGNAL, historized (the event is done) and removed from the active table, analog to the other end states.

addTriggers

public <T extends Serializable>
@NonNull List<RunningTriggerEntity> addTriggers(Collection<TriggerRequest<T>> newTriggers)

deleteAll

public void deleteAll()

deleteTrigger

public void deleteTrigger(RunningTriggerEntity trigger)

markTriggersAsRunning

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

triggerIsNowRunning

@Transactional(propagation=SUPPORTS)
public void triggerIsNowRunning(RunningTriggerEntity trigger,
 Serializable state)