Package com.persequor.saga.modules.ffmreader.subscription

Class FlightToEpcisSubscription

java.lang.Object

com.persequor.saga.modules.ffmreader.subscription.FlightToEpcisSubscription

All Implemented Interfaces:

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

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

Field Summary

Fields

Modifier and Type	Field	Description
static final com.persequor.event.BizStep	BIZ_STEP_FLIGHT_READY
static final com.persequor.event.BizTransactionType	BTT_FLIGHT_READY_ID

Constructor Summary

Constructors

Constructor	Description
FlightToEpcisSubscription(FlightToEpcisService service, CombinedFlightService combinedFlightService)

Method Summary

Modifier and Type	Method	Description
boolean	accept(com.persequor.event.Event event)
static <DbType extends IFileBasedFlight<?>> com.persequor.event.Event	createFlightOkayEvent(DbType flight)
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

Field Details

BTT_FLIGHT_READY_ID

public static final com.persequor.event.BizTransactionType BTT_FLIGHT_READY_ID

BIZ_STEP_FLIGHT_READY

public static final com.persequor.event.BizStep BIZ_STEP_FLIGHT_READY

Constructor Details

FlightToEpcisSubscription

@Inject
public FlightToEpcisSubscription(FlightToEpcisService service,
 CombinedFlightService combinedFlightService)

Method Details

createFlightOkayEvent

public static <DbType extends IFileBasedFlight<?>>
com.persequor.event.Event createFlightOkayEvent(DbType flight)

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