Package com.persequor.saga.modules.timebasedlogic.subscription

Class TimeBasedEventTriggerSubscription

java.lang.Object

com.persequor.saga.modules.timebasedlogic.subscription.TimeBasedEventTriggerSubscription

All Implemented Interfaces:

com.persequor.extension.subscription.ISubscriptionExtension, com.persequor.extension.subscription.ISubscriptionProcessor

public class TimeBasedEventTriggerSubscription
extends Object
implements com.persequor.extension.subscription.ISubscriptionExtension

Constructor Summary

Constructors

Constructor	Description
TimeBasedEventTriggerSubscription(TimeBasedEventRuleProvider eventRuleProvider, javax.inject.Provider<ITimeBasedEventTriggerEnabler> triggerEnablerProvider, javax.inject.Provider<ITimeBasedEventTriggerRevoker> triggerRevokerProvider, com.persequor.extension.document.IFailedReasonRegistry failedReasonRegistry)

Method Summary

Modifier and Type	Method	Description
boolean	accept(com.persequor.event.Event event)
com.persequor.extension.subscription.ProcessingMode	getProcessingOption()
void	process(com.persequor.event.EventList events)

Methods inherited from class java.lang.Object

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

Constructor Details

TimeBasedEventTriggerSubscription

@Inject
public TimeBasedEventTriggerSubscription(TimeBasedEventRuleProvider eventRuleProvider,
 javax.inject.Provider<ITimeBasedEventTriggerEnabler> triggerEnablerProvider,
 javax.inject.Provider<ITimeBasedEventTriggerRevoker> triggerRevokerProvider,
 com.persequor.extension.document.IFailedReasonRegistry failedReasonRegistry)

Method Details

accept

public boolean accept(com.persequor.event.Event event)

Specified by:

accept in interface com.persequor.extension.subscription.ISubscriptionExtension

getProcessingOption

public com.persequor.extension.subscription.ProcessingMode getProcessingOption()

Specified by:

getProcessingOption in interface com.persequor.extension.subscription.ISubscriptionExtension

process

public void process(com.persequor.event.EventList events)
             throws com.persequor.extension.subscription.SubscriptionDelayException,
com.persequor.extension.subscription.SubscriptionFailedException

Specified by:

process in interface com.persequor.extension.subscription.ISubscriptionProcessor

Throws:

com.persequor.extension.subscription.SubscriptionDelayException

com.persequor.extension.subscription.SubscriptionFailedException