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> TriggerEntity	addTrigger(AddTriggerRequest<T> tigger)
<T extends Serializable> List<TriggerEntity>	addTriggers(Collection<AddTriggerRequest<T>> newTriggers)
Optional<TriggerEntity>	cancelTask(TriggerKey id, Exception e)
Optional<TriggerEntity>	completeTaskWithSuccess(TriggerKey key, Serializable state)
void	deleteAll()
void	deleteTrigger(TriggerEntity trigger)
Optional<TriggerEntity>	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)
void	triggerIsNowRunning(TriggerEntity 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<TriggerEntity> completeTaskWithSuccess(TriggerKey key,
 Serializable state)

failTrigger

public Optional<TriggerEntity> 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<TriggerEntity> cancelTask(TriggerKey id,
 Exception e)

addTrigger

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

addTriggers

@NonNull
public <T extends Serializable> List<TriggerEntity> addTriggers(Collection<AddTriggerRequest<T>> newTriggers)

deleteAll

public void deleteAll()

deleteTrigger

public void deleteTrigger(TriggerEntity trigger)

markTriggersAsRunning

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

triggerIsNowRunning

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