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

Class TriggerFiringJobSubscription

java.lang.Object

com.persequor.saga.modules.timebasedlogic.subscription.TriggerFiringJobSubscription

All Implemented Interfaces:

com.persequor.extension.subscription.IAdvancedSubscriptionProcessor

public class TriggerFiringJobSubscription
extends Object
implements com.persequor.extension.subscription.IAdvancedSubscriptionProcessor

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ADDITIONAL_DATA_FIELD_NAME
static final String	ADDITIONAL_DATA_PREFIX

Constructor Summary

Constructors

Constructor	Description
TriggerFiringJobSubscription(TimeBasedEventRuleService eventRuleService, TimeBasedTriggerService triggerService, com.persequor.extension.document.IFailedReasonRegistry failedReasonRegistry)

Method Summary

Modifier and Type	Method	Description
void	process(com.persequor.event.EventList events, com.persequor.extension.AdditionalData additionalData)

Methods inherited from class java.lang.Object

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

Field Details

ADDITIONAL_DATA_PREFIX

public static final String ADDITIONAL_DATA_PREFIX

See Also:

• Constant Field Values

ADDITIONAL_DATA_FIELD_NAME

public static final String ADDITIONAL_DATA_FIELD_NAME

See Also:

• Constant Field Values

Constructor Details

TriggerFiringJobSubscription

@Inject
public TriggerFiringJobSubscription(TimeBasedEventRuleService eventRuleService,
 TimeBasedTriggerService triggerService,
 com.persequor.extension.document.IFailedReasonRegistry failedReasonRegistry)

Method Details

process

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

Specified by:

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

Throws:

com.persequor.extension.subscription.SubscriptionDelayException

com.persequor.extension.subscription.SubscriptionFailedException