Package | Description |
---|---|
org.axonframework.config |
Modifier and Type | Method and Description |
---|---|
SagaConfiguration<S> |
SagaConfiguration.configureErrorHandler(Function<Configuration,ErrorHandler> errorHandler)
Configures the ErrorHandler to use when an error occurs processing an Event.
|
SagaConfiguration<S> |
SagaConfiguration.configureMessageMonitor(Function<Configuration,MessageMonitor<? super EventMessage<?>>> messageMonitor)
Configures a MessageMonitor to be used to monitor Events processed on by the Saga being configured.
|
SagaConfiguration<S> |
SagaConfiguration.configureRollbackConfiguration(Function<Configuration,RollbackConfiguration> rollbackConfiguration)
Defines the policy to roll back or commit a Unit of Work in case exceptions occur.
|
SagaConfiguration<S> |
SagaConfiguration.configureSagaStore(Function<Configuration,SagaStore<? super S>> sagaStoreBuilder)
Configures the Saga Store to use to store Saga instances of this type.
|
SagaConfiguration<S> |
SagaConfiguration.configureTokenStore(Function<Configuration,TokenStore> tokenStore)
Registers the given
tokenStore for use by a TrackingProcessor for the Saga being configured. |
SagaConfiguration<S> |
SagaConfiguration.configureTrackingProcessor(Function<Configuration,TrackingEventProcessorConfiguration> trackingEventProcessorConfiguration)
Registers the
TrackingEventProcessorConfiguration to use when building the processor for this Saga type. |
SagaConfiguration<S> |
SagaConfiguration.configureTransactionManager(Function<Configuration,TransactionManager> transactionManager)
Defines the Transaction Manager to use when processing Events for this Saga.
|
SagaConfiguration<S> |
SagaConfiguration.registerHandlerInterceptor(Function<Configuration,MessageHandlerInterceptor<? super EventMessage<?>>> handlerInterceptorBuilder)
Registers the handler interceptor provided by the given
handlerInterceptorBuilder function with
the processor defined in this configuration. |
static <S> SagaConfiguration<S> |
SagaConfiguration.subscribingSagaManager(Class<S> sagaType)
Initialize a configuration for a Saga of given
sagaType , using a Subscribing Event Processor to process
incoming Events. |
static <S> SagaConfiguration<S> |
SagaConfiguration.subscribingSagaManager(Class<S> sagaType,
Function<Configuration,SubscribableMessageSource<EventMessage<?>>> messageSourceBuilder)
Initialize a configuration for a Saga of given
sagaType , using a Subscribing Event Processor to process
incoming Events from the message source provided by given messageSourceBuilder |
static <S> SagaConfiguration<S> |
SagaConfiguration.subscribingSagaManager(Class<S> sagaType,
Function<Configuration,SubscribableMessageSource<EventMessage<?>>> messageSourceBuilder,
Function<Configuration,EventProcessingStrategy> eventProcessingStrategy)
Initialize a configuration for a Saga of given
sagaType , using a Subscribing Event Processor to process
incoming Events from the message source provided by given messageSourceBuilder . |
static <S> SagaConfiguration<S> |
SagaConfiguration.trackingSagaManager(Class<S> sagaType)
Initialize a configuration for a Saga of given
sagaType , using a Tracking Event Processor to process
incoming Events. |
static <S> SagaConfiguration<S> |
SagaConfiguration.trackingSagaManager(Class<S> sagaType,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> messageSourceBuilder)
Initialize a configuration for a Saga of given
sagaType , using a Tracking Event Processor to process
incoming Events from a Message Source provided by given messageSourceBuilder . |
Copyright © 2010–2017. All rights reserved.