org.axonframework.config

Class SagaConfiguration<S>

java.lang.Object

org.axonframework.config.SagaConfiguration<S>

All Implemented Interfaces:

ModuleConfiguration

public class SagaConfiguration<S>
extends Object
implements ModuleConfiguration

Module Configuration implementation that defines a Saga. This component allows the configuration of the type of Event Processor used, as well as where to store Saga instances.

Method Summary

Modifier and Type	Method and Description
SagaConfiguration<S>	configureSagaStore(Function<Configuration,SagaStore<? super S>> sagaStoreBuilder) Configures the Saga Store to use to store Saga instances of this type.
EventProcessor	getProcessor() Returns the processor that processed events for the Saga in this Configuration.
AnnotatedSagaManager<S>	getSagaManager() Returns the SagaManager responsible for managing the lifecycle and invocation of Saga instances of the type defined in this Configuration
SagaRepository<S>	getSagaRepository() Returns the SagaRepository instance used to load Saga instances in this Configuration.
SagaStore<? super S>	getSagaStore() Returns the Saga Store used by the Saga defined in this Configuration.
void	initialize(Configuration config) Initialize the module configuration using the given global config
SagaConfiguration<S>	registerHandlerInterceptor(Function<Configuration,MessageHandlerInterceptor<? super EventMessage<?>>> handlerInterceptorBuilder) Registers the handler interceptor provided by the given handlerInterceptorBuilder function with the processor defined in this configuration.
void	shutdown() Invoked prior to shutdown of the application.
void	start() Invoked when the Configuration is started.
static <S> SagaConfiguration<S>	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>	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>	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>	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.

Methods inherited from class java.lang.Object

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

Method Detail

subscribingSagaManager

public static <S> SagaConfiguration<S> subscribingSagaManager(Class<S> sagaType)

Initialize a configuration for a Saga of given sagaType, using a Subscribing Event Processor to process incoming Events.

Type Parameters:

S - The type of Saga configured in this configuration

Parameters:

sagaType - The type of Saga to handle events with

Returns:

a SagaConfiguration instance, ready for further configuration

subscribingSagaManager

public static <S> SagaConfiguration<S> 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

Type Parameters:

S - The type of Saga configured in this configuration

Parameters:

sagaType - The type of Saga to handle events with

messageSourceBuilder - The function providing the message source based on the configuration

Returns:

a SagaConfiguration instance, ready for further configuration

trackingSagaManager

public static <S> SagaConfiguration<S> trackingSagaManager(Class<S> sagaType)

Initialize a configuration for a Saga of given sagaType, using a Tracking Event Processor to process incoming Events. Note that a Token Store should be configured in the global configuration, or the Saga Manager will default to an in-memory token store, which is not recommended for production environments.

Type Parameters:

S - The type of Saga configured in this configuration

Parameters:

sagaType - The type of Saga to handle events with

Returns:

a SagaConfiguration instance, ready for further configuration

trackingSagaManager

public static <S> SagaConfiguration<S> 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. Note that a Token Store should be configured in the global configuration, or the Saga Manager will default to an in-memory token store, which is not recommended for production environments.

Type Parameters:

S - The type of Saga configured in this configuration

Parameters:

sagaType - The type of Saga to handle events with

messageSourceBuilder - The function providing the message source based on the configuration

Returns:

a SagaConfiguration instance, ready for further configuration

configureSagaStore

public SagaConfiguration<S> configureSagaStore(Function<Configuration,SagaStore<? super S>> sagaStoreBuilder)

Configures the Saga Store to use to store Saga instances of this type. By default, Sagas are stored in the Saga Store configured in the global Configuration. This method can be used to override the store for specific Sagas.

Parameters:

sagaStoreBuilder - The builder that returnes a fully initialized Saga Store instance based on the global Configuration

Returns:

this SagaConfiguration instance, ready for further configuration

registerHandlerInterceptor

public SagaConfiguration<S> registerHandlerInterceptor(Function<Configuration,MessageHandlerInterceptor<? super EventMessage<?>>> handlerInterceptorBuilder)

Registers the handler interceptor provided by the given handlerInterceptorBuilder function with the processor defined in this configuration.

Parameters:

handlerInterceptorBuilder - The function to create the interceptor based on the current configuration

Returns:

this SagaConfiguration instance, ready for further configuration

initialize

public void initialize(Configuration config)

Description copied from interface: ModuleConfiguration

Initialize the module configuration using the given global config

Specified by:

initialize in interface ModuleConfiguration

Parameters:

config - the global configuration, providing access to generic components

start

public void start()

Description copied from interface: ModuleConfiguration

Invoked when the Configuration is started.

Specified by:

start in interface ModuleConfiguration

See Also:

Configuration.start()

getProcessor

public EventProcessor getProcessor()

Returns the processor that processed events for the Saga in this Configuration.

Returns:

The EventProcessor defined in this Configuration

Throws:

IllegalStateException - when this configuration hasn't been initialized yet

getSagaStore

public SagaStore<? super S> getSagaStore()

Returns the Saga Store used by the Saga defined in this Configuration. If none has been explicitly defined, it will return the Saga Store of the main Configuration.

Returns:

The Saga Store defined in this Configuration

Throws:

IllegalStateException - when this configuration hasn't been initialized yet

getSagaRepository

public SagaRepository<S> getSagaRepository()

Returns the SagaRepository instance used to load Saga instances in this Configuration.

Returns:

the SagaRepository defined in this Configuration

Throws:

IllegalStateException - when this configuration hasn't been initialized yet

getSagaManager

public AnnotatedSagaManager<S> getSagaManager()

Returns the SagaManager responsible for managing the lifecycle and invocation of Saga instances of the type defined in this Configuration

Returns:

The SagaManager defined in this configuration

Throws:

IllegalStateException - when this configuration hasn't been initialized yet

shutdown

public void shutdown()

Description copied from interface: ModuleConfiguration

Invoked prior to shutdown of the application.

Specified by:

shutdown in interface ModuleConfiguration

See Also:

Configuration.shutdown()