Package com.persequor.saga.modules.timebasedlogic.service

Class TimeBasedTriggerService

java.lang.Object

com.persequor.saga.modules.timebasedlogic.service.TimeBasedTriggerService

@Singleton
public class TimeBasedTriggerService
extends Object

Constructor Summary

Constructors

Constructor	Description
TimeBasedTriggerService(ITimeBasedTriggerRepository repository, IModelFactory modelFactory, TimeBasedConfig timeBasedConfig, DateService dateService)

Method Summary

Modifier and Type	Method	Description
void	addTriggers(String processorId, Class<?> processorDataType, String processorDataId, Map<String,ZonedDateTime> triggerKeyToFireAt, Object additionalData)
void	deleteTrigger(UUID id)
void	deleteTriggerByProcessorDataId(String processorId, Class<?> processorDataType, String processorDataId)
void	deleteTriggerByTriggerKey(String processorId, Class<?> processorDataType, String triggerKey)
Optional<TimeBasedTrigger>	getTrigger(UUID id)
List<TimeBasedTrigger>	getTriggers(Integer limit, Integer offset)
List<TimeBasedTrigger>	getTriggers(String ruleId, Class<?> processorDataType, String triggerKey)
List<TimeBasedTrigger>	getTriggersDueToBeFired()
List<TimeBasedTrigger>	getTriggersForEvent(com.persequor.event.Event event, int pageSize)
void	markAsFired(TimeBasedTrigger trigger)

Methods inherited from class java.lang.Object

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

Constructor Details

TimeBasedTriggerService

@Inject
public TimeBasedTriggerService(ITimeBasedTriggerRepository repository,
 IModelFactory modelFactory,
 TimeBasedConfig timeBasedConfig,
 DateService dateService)

Method Details

getTriggers

public List<TimeBasedTrigger> getTriggers(Integer limit,
 Integer offset)

getTriggers

public List<TimeBasedTrigger> getTriggers(String ruleId,
 Class<?> processorDataType,
 String triggerKey)

getTriggersForEvent

public List<TimeBasedTrigger> getTriggersForEvent(com.persequor.event.Event event,
 int pageSize)

getTrigger

public Optional<TimeBasedTrigger> getTrigger(UUID id)

getTriggersDueToBeFired

public List<TimeBasedTrigger> getTriggersDueToBeFired()

markAsFired

public void markAsFired(TimeBasedTrigger trigger)

addTriggers

public void addTriggers(String processorId,
 Class<?> processorDataType,
 String processorDataId,
 Map<String,ZonedDateTime> triggerKeyToFireAt,
 Object additionalData)

deleteTriggerByTriggerKey

public void deleteTriggerByTriggerKey(String processorId,
 Class<?> processorDataType,
 String triggerKey)

deleteTrigger

public void deleteTrigger(UUID id)

deleteTriggerByProcessorDataId

public void deleteTriggerByProcessorDataId(String processorId,
 Class<?> processorDataType,
 String processorDataId)