Package org.axonframework.config

Interface EventProcessingConfigurer

All Known Implementing Classes:

EventProcessingModule

public interface EventProcessingConfigurer

Defines a contract for configuring event processing.

Since:

4.0

Author:

Milan Savic

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	EventProcessingConfigurer.DeadLetteringInvokerConfiguration	Contract defining DeadLetteringEventHandlerInvoker.Builder based configuration when constructing a DeadLetteringEventHandlerInvoker.
static interface	EventProcessingConfigurer.EventProcessorBuilder	Contract which defines how to build an event processor.
static interface	EventProcessingConfigurer.PooledStreamingProcessorConfiguration	Contract defining PooledStreamingEventProcessor.Builder based configuration when constructing a PooledStreamingEventProcessor.
static interface	EventProcessingConfigurer.SubscribableMessageSourceDefinitionBuilder	Contract which define how to build SubscribableMessageSourceDefinition

Method Summary

Modifier and Type	Method	Description
EventProcessingConfigurer	assignHandlerInstancesMatching(String processingGroup, int priority, Predicate<Object> criteria)	Configures a rule to assign Event Handler beans that match the given criteria to the Processing Group with given name, with given priority.
default EventProcessingConfigurer	assignHandlerInstancesMatching(String processingGroup, Predicate<Object> criteria)	Configures a rule to assign Event Handler beans that match the given criteria to the Processing Group with given name, with neutral priority (value 0).
EventProcessingConfigurer	assignHandlerTypesMatching(String processingGroup, int priority, Predicate<Class<?>> criteria)	Configures a rule to assign Event Handler beans that match the given criteria to the Processing Group with given name, with given priority.
default EventProcessingConfigurer	assignHandlerTypesMatching(String processingGroup, Predicate<Class<?>> criteria)	Configures a rule to assign Event Handler beans that match the given criteria to the Processing Group with given name, with neutral priority (value 0).
EventProcessingConfigurer	assignProcessingGroup(String processingGroup, String processorName)	Defines a mapping for assigning processing groups to processors.
EventProcessingConfigurer	assignProcessingGroup(Function<String,String> assignmentRule)	Defines a rule for assigning processing groups to processors if processing group to processor name mapping does not contain the entry.
EventProcessingConfigurer	byDefaultAssignHandlerInstancesTo(Function<Object,String> assignmentFunction)	Registers a Function that defines the Event Processing Group name to assign Event Handler beans to when no other, more explicit, rule matches and no ProcessingGroup annotation is found.
EventProcessingConfigurer	byDefaultAssignHandlerTypesTo(Function<Class<?>,String> assignmentFunction)	Registers a Function that defines the Event Processing Group name to assign Event Handler and Saga beans to when no other, more explicit, rule matches and no ProcessingGroup annotation is found.
default EventProcessingConfigurer	byDefaultAssignTo(String processingGroup)	Registers the processingGroup name to assign Event Handler and Saga beans to when no other, more explicit, rule matches and no ProcessingGroup annotation is found.
EventProcessingConfigurer	configureDefaultStreamableMessageSource(Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> defaultSource)	Configures which StreamableMessageSource to use for Tracking Event Processors if none was explicitly provided.
EventProcessingConfigurer	configureDefaultSubscribableMessageSource(Function<Configuration,SubscribableMessageSource<EventMessage<?>>> defaultSource)	Configures which SubscribableMessageSource to use for Subscribing Event Processors if none was explicitly provided.
default EventProcessingConfigurer	registerDeadLetteringEventHandlerInvokerConfiguration(String processingGroup, EventProcessingConfigurer.DeadLetteringInvokerConfiguration configuration)	Register a EventProcessingConfigurer.DeadLetteringInvokerConfiguration for the given processingGroup.
default EventProcessingConfigurer	registerDeadLetterPolicy(String processingGroup, Function<Configuration,EnqueuePolicy<EventMessage<?>>> policyBuilder)	Register a dead letter policy for the given processingGroup using a dead letter queue.
default EventProcessingConfigurer	registerDeadLetterQueue(String processingGroup, Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>> queueBuilder)	Register a SequencedDeadLetterQueue for the given processingGroup.
default EventProcessingConfigurer	registerDeadLetterQueueProvider(Function<String,Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>>> deadLetterQueueProvider)	Register the given deadLetterProvider as a default to build a SequencedDeadLetterQueue for EventProcessors created in this configuration.
default EventProcessingConfigurer	registerDefaultDeadLetterPolicy(Function<Configuration,EnqueuePolicy<EventMessage<?>>> policyBuilder)	Register a default dead letter policy for any processing group using a dead letter queue.
EventProcessingConfigurer	registerDefaultErrorHandler(Function<Configuration,ErrorHandler> errorHandlerBuilder)	Registers a Function that builds the default ErrorHandler.
EventProcessingConfigurer	registerDefaultHandlerInterceptor(BiFunction<Configuration,String,MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder)	Register the given interceptorBuilder as a default to build a MessageHandlerInterceptor for EventProcessors created in this configuration.
EventProcessingConfigurer	registerDefaultListenerInvocationErrorHandler(Function<Configuration,ListenerInvocationErrorHandler> listenerInvocationErrorHandlerBuilder)	Registers a Function that builds the default ListenerInvocationErrorHandler.
EventProcessingConfigurer	registerDefaultSequencingPolicy(Function<Configuration,SequencingPolicy<? super EventMessage<?>>> policyBuilder)	Registers the SequencingPolicy created by given policyBuilder to the processing groups for which no explicit policy is defined (using registerSequencingPolicy(String, Function)).
EventProcessingConfigurer	registerDefaultTransactionManager(Function<Configuration,TransactionManager> transactionManagerBuilder)	Registers a default TransactionManager for all EventProcessors.
EventProcessingConfigurer	registerErrorHandler(String eventProcessorName, Function<Configuration,ErrorHandler> errorHandlerBuilder)	Registers a Function that builds an ErrorHandler for the given eventProcessorName.
EventProcessingConfigurer	registerEventHandler(Function<Configuration,Object> eventHandlerBuilder)	Registers a Function that builds an Event Handler instance.
EventProcessingConfigurer	registerEventProcessor(String name, EventProcessingConfigurer.EventProcessorBuilder eventProcessorBuilder)	Registers an EventProcessingConfigurer.EventProcessorBuilder for the given processor name.
EventProcessingConfigurer	registerEventProcessorFactory(EventProcessingConfigurer.EventProcessorBuilder eventProcessorBuilder)	Registers a factory that builds the default EventProcessor.
EventProcessingConfigurer	registerHandlerInterceptor(String processorName, Function<Configuration,MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder)	Register the given interceptorBuilder to build a MessageHandlerInterceptor for the EventProcessor with given processorName.
EventProcessingConfigurer	registerListenerInvocationErrorHandler(String processingGroup, Function<Configuration,ListenerInvocationErrorHandler> listenerInvocationErrorHandlerBuilder)	Registers a Function that builds a ListenerInvocationErrorHandler for the given processingGroup.
default EventProcessingConfigurer	registerMessageMonitor(String eventProcessorName, Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder)	Registers a builder Function to create the MessageMonitor for a EventProcessor of the given name.
EventProcessingConfigurer	registerMessageMonitorFactory(String eventProcessorName, MessageMonitorFactory messageMonitorFactory)	Registers the factory to create the MessageMonitor for a EventProcessor of the given name.
default EventProcessingConfigurer	registerPooledStreamingEventProcessor(String name)	Registers a PooledStreamingEventProcessor in this EventProcessingConfigurer.
default EventProcessingConfigurer	registerPooledStreamingEventProcessor(String name, Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> messageSource)	Registers a PooledStreamingEventProcessor in this EventProcessingConfigurer.
EventProcessingConfigurer	registerPooledStreamingEventProcessor(String name, Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> messageSource, EventProcessingConfigurer.PooledStreamingProcessorConfiguration processorConfiguration)	Registers a PooledStreamingEventProcessor in this EventProcessingConfigurer.
EventProcessingConfigurer	registerPooledStreamingEventProcessorConfiguration(String name, EventProcessingConfigurer.PooledStreamingProcessorConfiguration pooledStreamingProcessorConfiguration)	Register a EventProcessingConfigurer.PooledStreamingProcessorConfiguration to be used when constructing a PooledStreamingEventProcessor with name.
EventProcessingConfigurer	registerPooledStreamingEventProcessorConfiguration(EventProcessingConfigurer.PooledStreamingProcessorConfiguration pooledStreamingProcessorConfiguration)	Register a default EventProcessingConfigurer.PooledStreamingProcessorConfiguration to be used when constructing every PooledStreamingEventProcessor.
EventProcessingConfigurer	registerRollbackConfiguration(String name, Function<Configuration,RollbackConfiguration> rollbackConfigurationBuilder)	Registers a Function that builds the RollbackConfiguration for given processor name.
default <T> EventProcessingConfigurer	registerSaga(Class<T> sagaType)	Registers a Saga with default configuration within this Configurer.
<T> EventProcessingConfigurer	registerSaga(Class<T> sagaType, Consumer<SagaConfigurer<T>> sagaConfigurer)	Registers a Saga, allowing specific configuration to use for this Saga type.
EventProcessingConfigurer	registerSagaStore(Function<Configuration,SagaStore> sagaStoreBuilder)	Registers a Function that builds a SagaStore.
EventProcessingConfigurer	registerSequencingPolicy(String processingGroup, Function<Configuration,SequencingPolicy<? super EventMessage<?>>> policyBuilder)	Registers the SequencingPolicy created by the given policyBuilder to the processing group with given processingGroup.
default EventProcessingConfigurer	registerSubscribingEventProcessor(String name)	Registers a SubscribingEventProcessor with given name within this Configurer.
EventProcessingConfigurer	registerSubscribingEventProcessor(String name, Function<Configuration,SubscribableMessageSource<? extends EventMessage<?>>> messageSource)	Registers a SubscribingEventProcessor with given name and messageSource within this Configuration.
EventProcessingConfigurer	registerTokenStore(String processorName, Function<Configuration,TokenStore> tokenStoreBuilder)	Register a Function that builds a TokenStore for the given processorName.
EventProcessingConfigurer	registerTokenStore(Function<Configuration,TokenStore> tokenStore)	Register a Function that builds a TokenStore to use as the default in case no explicit token store was configured for a processor.
default EventProcessingConfigurer	registerTrackingEventProcessor(String name)	Registers a TrackingEventProcessor with given name within this Configurer.
EventProcessingConfigurer	registerTrackingEventProcessor(String name, Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source)	Registers a TrackingEventProcessor with given name and source within this Configurer.
EventProcessingConfigurer	registerTrackingEventProcessor(String name, Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source, Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration)	Registers a TrackingEventProcessor with given name, source and processorConfiguration within this Configurer.
EventProcessingConfigurer	registerTrackingEventProcessorConfiguration(String name, Function<Configuration,TrackingEventProcessorConfiguration> trackingEventProcessorConfigurationBuilder)	Register a Function that builds a TrackingEventProcessorConfiguration to be used by the EventProcessor corresponding to the given name.
EventProcessingConfigurer	registerTrackingEventProcessorConfiguration(Function<Configuration,TrackingEventProcessorConfiguration> trackingEventProcessorConfigurationBuilder)	Register a Function that builds a TrackingEventProcessorConfiguration to use as the default.
EventProcessingConfigurer	registerTransactionManager(String name, Function<Configuration,TransactionManager> transactionManagerBuilder)	Registers a TransactionManager for a EventProcessor of the given name.
EventProcessingConfigurer	usingPooledStreamingEventProcessors()	Defaults Event Processors builders to use PooledStreamingEventProcessor.
default EventProcessingConfigurer	usingPooledStreamingEventProcessors(EventProcessingConfigurer.PooledStreamingProcessorConfiguration pooledStreamingProcessorConfiguration)	Defaults Event Processors builders to construct a PooledStreamingEventProcessor using the configuration to configure them.
EventProcessingConfigurer	usingSubscribingEventProcessors()	Defaults Event Processors builders to use SubscribingEventProcessor.
default EventProcessingConfigurer	usingSubscribingEventProcessors(EventProcessingConfigurer.SubscribableMessageSourceDefinitionBuilder builder)	If this method is invoked, Subscribing Event Processors will be created for all processing groups if none was explicitly provided.
EventProcessingConfigurer	usingTrackingEventProcessors()	Defaults Event Processors builders to use TrackingEventProcessor.

Method Details

registerSaga

default <T> EventProcessingConfigurer registerSaga(Class<T> sagaType)

Registers a Saga with default configuration within this Configurer.

Type Parameters:

T - the type of Saga

Parameters:

sagaType - the type of Saga

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerSaga

<T> EventProcessingConfigurer registerSaga(Class<T> sagaType,
 Consumer<SagaConfigurer<T>> sagaConfigurer)

Registers a Saga, allowing specific configuration to use for this Saga type.

Type Parameters:

T - The type of Saga to configure

Parameters:

sagaType - The type of Saga to configure

sagaConfigurer - a function providing modifications on top of the default configuration

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerSagaStore

EventProcessingConfigurer registerSagaStore(Function<Configuration,SagaStore> sagaStoreBuilder)

Registers a Function that builds a SagaStore.

Parameters:

sagaStoreBuilder - a Function that builds a SagaStore

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerEventHandler

EventProcessingConfigurer registerEventHandler(Function<Configuration,Object> eventHandlerBuilder)

Registers a Function that builds an Event Handler instance.

Parameters:

eventHandlerBuilder - a Function that builds an Event Handler instance

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerDefaultListenerInvocationErrorHandler

EventProcessingConfigurer registerDefaultListenerInvocationErrorHandler(Function<Configuration,ListenerInvocationErrorHandler> listenerInvocationErrorHandlerBuilder)

Registers a Function that builds the default ListenerInvocationErrorHandler. Defaults to a LoggingErrorHandler.

Parameters:

listenerInvocationErrorHandlerBuilder - a Function that builds the default ListenerInvocationErrorHandler

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerListenerInvocationErrorHandler

EventProcessingConfigurer registerListenerInvocationErrorHandler(String processingGroup,
 Function<Configuration,ListenerInvocationErrorHandler> listenerInvocationErrorHandlerBuilder)

Registers a Function that builds a ListenerInvocationErrorHandler for the given processingGroup.

Parameters:

processingGroup - a String specifying the name of a processing group

listenerInvocationErrorHandlerBuilder - a Function that builds ListenerInvocationErrorHandler

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerTrackingEventProcessor

default EventProcessingConfigurer registerTrackingEventProcessor(String name)

Registers a TrackingEventProcessor with given name within this Configurer.

Parameters:

name - a String specifying the name of the TrackingEventProcessor being registered

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

configureDefaultStreamableMessageSource

EventProcessingConfigurer configureDefaultStreamableMessageSource(Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> defaultSource)

Configures which StreamableMessageSource to use for Tracking Event Processors if none was explicitly provided. Defaults to the Event Bus (or Store) available in the Configuration.

Note that the configuration of a default source does not change how the decision is made to select the type of processor. Unless explicitly specified using usingSubscribingEventProcessors() or usingTrackingEventProcessors(), the default is dependent on the type of Message Source the Event Bus provides. If the Event Bus supports Tracking Processors, that is the default, otherwise Subscribing Event Processors are the default.

Parameters:

defaultSource - a Function that defines the Message source to use

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

configureDefaultSubscribableMessageSource

EventProcessingConfigurer configureDefaultSubscribableMessageSource(Function<Configuration,SubscribableMessageSource<EventMessage<?>>> defaultSource)

Configures which SubscribableMessageSource to use for Subscribing Event Processors if none was explicitly provided. Defaults to the Event Bus (or Store) available in the Configuration.

Note that the configuration of a default source does not change how the decision is made to select the type of processor. Unless explicitly specified using usingSubscribingEventProcessors() or usingTrackingEventProcessors(), the default is dependent on the type of Message Source the Event Bus provides. If the Event Bus supports Tracking Processors, that is the default, otherwise Subscribing Event Processors are the default.

Parameters:

defaultSource - a Function that defines the Message source to use

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerTrackingEventProcessor

EventProcessingConfigurer registerTrackingEventProcessor(String name,
 Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source)

Registers a TrackingEventProcessor with given name and source within this Configurer.

Parameters:

name - a String specifying the name of the TrackingEventProcessor being registered

source - a Function that builds a StreamableMessageSource

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerTrackingEventProcessor

EventProcessingConfigurer registerTrackingEventProcessor(String name,
 Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source,
 Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration)

Registers a TrackingEventProcessor with given name, source and processorConfiguration within this Configurer.

Parameters:

name - a String specifying the name of the TrackingEventProcessor being registered

source - a Function that builds StreamableMessageSource

processorConfiguration - a Function that builds a TrackingEventProcessorConfiguration

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerEventProcessorFactory

EventProcessingConfigurer registerEventProcessorFactory(EventProcessingConfigurer.EventProcessorBuilder eventProcessorBuilder)

Registers a factory that builds the default EventProcessor. This is the EventProcessingConfigurer.EventProcessorBuilder to be used when there is no specific builder for given processor name.

Parameters:

eventProcessorBuilder - a Function that builds an EventProcessor

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerEventProcessor

EventProcessingConfigurer registerEventProcessor(String name,
 EventProcessingConfigurer.EventProcessorBuilder eventProcessorBuilder)

Registers an EventProcessingConfigurer.EventProcessorBuilder for the given processor name.

Parameters:

name - a String specifying the name of the EventProcessor being registered

eventProcessorBuilder - a Function that builds an EventProcessor

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerTokenStore

EventProcessingConfigurer registerTokenStore(String processorName,
 Function<Configuration,TokenStore> tokenStoreBuilder)

Register a Function that builds a TokenStore for the given processorName.

Parameters:

processorName - a String specifying the name of a event processor

tokenStoreBuilder - a Function that builds a TokenStore

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerTokenStore

EventProcessingConfigurer registerTokenStore(Function<Configuration,TokenStore> tokenStore)

Register a Function that builds a TokenStore to use as the default in case no explicit token store was configured for a processor.

Parameters:

tokenStore - a Function that builds a TokenStore

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

usingSubscribingEventProcessors

EventProcessingConfigurer usingSubscribingEventProcessors()

Defaults Event Processors builders to use SubscribingEventProcessor.

The default behavior depends on the EventBus available in the Configuration. If the Event Bus is a StreamableMessageSource, processors are Tracking by default. This method must be used to force the use of Subscribing Processors, unless specifically overridden for individual processors.

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

usingTrackingEventProcessors

EventProcessingConfigurer usingTrackingEventProcessors()

Defaults Event Processors builders to use TrackingEventProcessor.

The default behavior depends on the EventBus available in the Configuration. If the Event Bus is a StreamableMessageSource, processors are Tracking by default. This method must be used to force the use of Tracking Processors, unless specifically overridden for individual processors.

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

usingPooledStreamingEventProcessors

EventProcessingConfigurer usingPooledStreamingEventProcessors()

Defaults Event Processors builders to use PooledStreamingEventProcessor.

The default behavior depends on the EventBus available in the Configuration. If the EventBus is a StreamableMessageSource, processors are Tracking by default. This method must be used to force the use of Pooled Streaming Processors, unless specifically overridden for individual processors.

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

usingPooledStreamingEventProcessors

default EventProcessingConfigurer usingPooledStreamingEventProcessors(EventProcessingConfigurer.PooledStreamingProcessorConfiguration pooledStreamingProcessorConfiguration)

Defaults Event Processors builders to construct a PooledStreamingEventProcessor using the configuration to configure them.

The default behavior depends on the EventBus available in the Configuration. If the EventBus is a StreamableMessageSource, processors are Tracking by default. This method must be used to force the use of Pooled Streaming Processors, unless specifically overridden for individual processors.

Parameters:

pooledStreamingProcessorConfiguration - configuration used when constructing every PooledStreamingEventProcessor

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerSubscribingEventProcessor

default EventProcessingConfigurer registerSubscribingEventProcessor(String name)

Registers a SubscribingEventProcessor with given name within this Configurer.

Parameters:

name - a String specyfing the name of the SubscribingEventProcessor being registered

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerSubscribingEventProcessor

EventProcessingConfigurer registerSubscribingEventProcessor(String name,
 Function<Configuration,SubscribableMessageSource<? extends EventMessage<?>>> messageSource)

Registers a SubscribingEventProcessor with given name and messageSource within this Configuration.

Parameters:

name - a String specyfing the name of the SubscribingEventProcessor being registered

messageSource - a Function that builds a SubscribableMessageSource

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerDefaultErrorHandler

EventProcessingConfigurer registerDefaultErrorHandler(Function<Configuration,ErrorHandler> errorHandlerBuilder)

Registers a Function that builds the default ErrorHandler. Defaults to a PropagatingErrorHandler.

Parameters:

errorHandlerBuilder - a Function that builds an ErrorHandler

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerErrorHandler

EventProcessingConfigurer registerErrorHandler(String eventProcessorName,
 Function<Configuration,ErrorHandler> errorHandlerBuilder)

Registers a Function that builds an ErrorHandler for the given eventProcessorName.

Parameters:

eventProcessorName - a String specifying the name of an EventProcessor

errorHandlerBuilder - a Function that builds an ErrorHandler

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

byDefaultAssignTo

default EventProcessingConfigurer byDefaultAssignTo(String processingGroup)

Registers the processingGroup name to assign Event Handler and Saga beans to when no other, more explicit, rule matches and no ProcessingGroup annotation is found.

Parameters:

processingGroup - a String specifying the name of a processing group

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

byDefaultAssignHandlerInstancesTo

EventProcessingConfigurer byDefaultAssignHandlerInstancesTo(Function<Object,String> assignmentFunction)

Registers a Function that defines the Event Processing Group name to assign Event Handler beans to when no other, more explicit, rule matches and no ProcessingGroup annotation is found.

Parameters:

assignmentFunction - a Function that returns the Processing Group for each Event Handler bean

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

byDefaultAssignHandlerTypesTo

EventProcessingConfigurer byDefaultAssignHandlerTypesTo(Function<Class<?>,String> assignmentFunction)

Registers a Function that defines the Event Processing Group name to assign Event Handler and Saga beans to when no other, more explicit, rule matches and no ProcessingGroup annotation is found.

Parameters:

assignmentFunction - a Function that returns the Processing Group for each Event Handler or Saga bean

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

assignHandlerInstancesMatching

default EventProcessingConfigurer assignHandlerInstancesMatching(String processingGroup,
 Predicate<Object> criteria)

Configures a rule to assign Event Handler beans that match the given criteria to the Processing Group with given name, with neutral priority (value 0).

Note that, when beans match multiple criteria for different Processing Groups with equal priority, the outcome is undefined.

Parameters:

processingGroup - a String specifying the name of a processing group to assign matching Event Handlers to

criteria - a Predicate defining the criteria for an Event Handler to match

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

assignHandlerTypesMatching

default EventProcessingConfigurer assignHandlerTypesMatching(String processingGroup,
 Predicate<Class<?>> criteria)

Configures a rule to assign Event Handler beans that match the given criteria to the Processing Group with given name, with neutral priority (value 0).

Note that, when beans match multiple criteria for different Processing Groups with equal priority, the outcome is undefined.

Parameters:

processingGroup - a String specifying the name of a processing group to assign matching Event Handlers or Sagas to

criteria - a Predicate defining the criteria for an Event Handler or Saga to match

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

assignHandlerInstancesMatching

EventProcessingConfigurer assignHandlerInstancesMatching(String processingGroup,
 int priority,
 Predicate<Object> criteria)

Configures a rule to assign Event Handler beans that match the given criteria to the Processing Group with given name, with given priority. Rules with higher value of priority take precedence over those with a lower value.

Note that, when beans match multiple criteria for different processing groups with equal priority, the outcome is undefined.

Parameters:

processingGroup - a String specifying the name of a processing group to assign matching Event Handlers to

priority - The priority for this rule

criteria - a Predicate defining the criteria for an Event Handler to match

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

assignHandlerTypesMatching

EventProcessingConfigurer assignHandlerTypesMatching(String processingGroup,
 int priority,
 Predicate<Class<?>> criteria)

Configures a rule to assign Event Handler beans that match the given criteria to the Processing Group with given name, with given priority. Rules with higher value of priority take precedence over those with a lower value.

Note that, when beans match multiple criteria for different processing groups with equal priority, the outcome is undefined.

Parameters:

processingGroup - a String specifying the name of the Processing Group to assign matching Event Handlers or Sagas to

priority - an int specifying the priority of this rule

criteria - a Predicate defining the criteria for an Event Handler or Saga to match

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

assignProcessingGroup

EventProcessingConfigurer assignProcessingGroup(String processingGroup,
 String processorName)

Defines a mapping for assigning processing groups to processors.

Parameters:

processingGroup - a String specifying the processing group to be assigned

processorName - a String specifying the processor name to assign the group to

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

assignProcessingGroup

EventProcessingConfigurer assignProcessingGroup(Function<String,String> assignmentRule)

Defines a rule for assigning processing groups to processors if processing group to processor name mapping does not contain the entry.

Parameters:

assignmentRule - a Function which takes a processing group and returns a processor name

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

See Also:

• assignProcessingGroup(String, String)

registerHandlerInterceptor

EventProcessingConfigurer registerHandlerInterceptor(String processorName,
 Function<Configuration,MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder)

Register the given interceptorBuilder to build a MessageHandlerInterceptor for the EventProcessor with given processorName.

The interceptorBuilder may return null, in which case the return value is ignored.

Parameters:

processorName - a String specyfing the name of the processor to register the MessageHandlerInterceptor on

interceptorBuilder - a Function providing the MessageHandlerInterceptor to register, or null

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerDefaultHandlerInterceptor

EventProcessingConfigurer registerDefaultHandlerInterceptor(BiFunction<Configuration,String,MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder)

Register the given interceptorBuilder as a default to build a MessageHandlerInterceptor for EventProcessors created in this configuration.

The interceptorBuilder is invoked once for each processor created, and may return null, in which case the return value is ignored.

Parameters:

interceptorBuilder - a builder Function that provides a MessageHandlerInterceptor for each available processor

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerSequencingPolicy

EventProcessingConfigurer registerSequencingPolicy(String processingGroup,
 Function<Configuration,SequencingPolicy<? super EventMessage<?>>> policyBuilder)

Registers the SequencingPolicy created by the given policyBuilder to the processing group with given processingGroup. Any previously configured policy for the same name will be overwritten.

Parameters:

processingGroup - a String specifying the name of the processing group to assign the SequencingPolicy for

policyBuilder - a builder Function to create the SequencingPolicy to use

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerDefaultSequencingPolicy

EventProcessingConfigurer registerDefaultSequencingPolicy(Function<Configuration,SequencingPolicy<? super EventMessage<?>>> policyBuilder)

Registers the SequencingPolicy created by given policyBuilder to the processing groups for which no explicit policy is defined (using registerSequencingPolicy(String, Function)).

Defaults to a SequentialPerAggregatePolicy.

Parameters:

policyBuilder - a builder Function to create the SequencingPolicy to use

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerMessageMonitor

default EventProcessingConfigurer registerMessageMonitor(String eventProcessorName,
 Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder)

Registers a builder Function to create the MessageMonitor for a EventProcessor of the given name.

Parameters:

eventProcessorName - a String specifying the name of an EventProcessor

messageMonitorBuilder - a builder Function to create a MessageMonitor

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerMessageMonitorFactory

EventProcessingConfigurer registerMessageMonitorFactory(String eventProcessorName,
 MessageMonitorFactory messageMonitorFactory)

Registers the factory to create the MessageMonitor for a EventProcessor of the given name.

Parameters:

eventProcessorName - a String specifying the name of an EventProcessor

messageMonitorFactory - a MessageMonitorFactory used to create a MessageMonitor

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerRollbackConfiguration

EventProcessingConfigurer registerRollbackConfiguration(String name,
 Function<Configuration,RollbackConfiguration> rollbackConfigurationBuilder)

Registers a Function that builds the RollbackConfiguration for given processor name. Defaults to a RollbackConfigurationType.ANY_THROWABLE

Parameters:

name - a String specifying the name of an EventProcessor

rollbackConfigurationBuilder - a Function that builds a RollbackConfiguration

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerTransactionManager

EventProcessingConfigurer registerTransactionManager(String name,
 Function<Configuration,TransactionManager> transactionManagerBuilder)

Registers a TransactionManager for a EventProcessor of the given name.

Parameters:

name - a String specifying the name of an EventProcessor

transactionManagerBuilder - a Function that builds a TransactionManager

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerDefaultTransactionManager

EventProcessingConfigurer registerDefaultTransactionManager(Function<Configuration,TransactionManager> transactionManagerBuilder)

Registers a default TransactionManager for all EventProcessors. The provided TransactionManager is used whenever no processor specific TransactionManager is configured.

Parameters:

transactionManagerBuilder - a Function that builds a TransactionManager

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerTrackingEventProcessorConfiguration

EventProcessingConfigurer registerTrackingEventProcessorConfiguration(String name,
 Function<Configuration,TrackingEventProcessorConfiguration> trackingEventProcessorConfigurationBuilder)

Register a Function that builds a TrackingEventProcessorConfiguration to be used by the EventProcessor corresponding to the given name.

Parameters:

name - a String specifying the name of an EventProcessor

trackingEventProcessorConfigurationBuilder - a Function that builds a TrackingEventProcessorConfiguration

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerTrackingEventProcessorConfiguration

EventProcessingConfigurer registerTrackingEventProcessorConfiguration(Function<Configuration,TrackingEventProcessorConfiguration> trackingEventProcessorConfigurationBuilder)

Register a Function that builds a TrackingEventProcessorConfiguration to use as the default.

Parameters:

trackingEventProcessorConfigurationBuilder - a Function that builds a TrackingEventProcessorConfiguration

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerPooledStreamingEventProcessor

default EventProcessingConfigurer registerPooledStreamingEventProcessor(String name)

Registers a PooledStreamingEventProcessor in this EventProcessingConfigurer. The processor will receive the given name.

Parameters:

name - the name of the PooledStreamingEventProcessor being registered

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerPooledStreamingEventProcessor

default EventProcessingConfigurer registerPooledStreamingEventProcessor(String name,
 Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> messageSource)

Registers a PooledStreamingEventProcessor in this EventProcessingConfigurer. The processor will receive the given name and use the outcome of the messageSource as the StreamableMessageSource.

Parameters:

name - the name of the PooledStreamingEventProcessor being registered

messageSource - constructs a StreamableMessageSource to be used by the PooledStreamingEventProcessor

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerPooledStreamingEventProcessor

EventProcessingConfigurer registerPooledStreamingEventProcessor(String name,
 Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> messageSource,
 EventProcessingConfigurer.PooledStreamingProcessorConfiguration processorConfiguration)

Registers a PooledStreamingEventProcessor in this EventProcessingConfigurer. The processor will receive the given name and use the outcome of the messageSource as the StreamableMessageSource.

The processorConfiguration will be used to further configure the PooledStreamingEventProcessor upon construction. Note that the processorConfiguration will override any configuration set through the registerPooledStreamingEventProcessorConfiguration(PooledStreamingProcessorConfiguration) and registerPooledStreamingEventProcessorConfiguration(String, PooledStreamingProcessorConfiguration).

Parameters:

name - the name of the PooledStreamingEventProcessor being registered

messageSource - constructs a StreamableMessageSource to be used by the PooledStreamingEventProcessor

processorConfiguration - allows further customization of the PooledStreamingEventProcessor under construction. The given Configuration can be used to extract components and use them in the PooledStreamingEventProcessor.Builder

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerPooledStreamingEventProcessorConfiguration

EventProcessingConfigurer registerPooledStreamingEventProcessorConfiguration(EventProcessingConfigurer.PooledStreamingProcessorConfiguration pooledStreamingProcessorConfiguration)

Register a default EventProcessingConfigurer.PooledStreamingProcessorConfiguration to be used when constructing every PooledStreamingEventProcessor.

Parameters:

pooledStreamingProcessorConfiguration - configuration used when constructing every PooledStreamingEventProcessor

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerPooledStreamingEventProcessorConfiguration

EventProcessingConfigurer registerPooledStreamingEventProcessorConfiguration(String name,
 EventProcessingConfigurer.PooledStreamingProcessorConfiguration pooledStreamingProcessorConfiguration)

Register a EventProcessingConfigurer.PooledStreamingProcessorConfiguration to be used when constructing a PooledStreamingEventProcessor with name.

Parameters:

name - the name of an PooledStreamingEventProcessor

pooledStreamingProcessorConfiguration - configuration used when constructing a PooledStreamingEventProcessor with the given name

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerDeadLetterQueue

default EventProcessingConfigurer registerDeadLetterQueue(@Nonnull
 String processingGroup,
 @Nonnull
 Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>> queueBuilder)

Register a SequencedDeadLetterQueue for the given processingGroup. The SequencedDeadLetterQueue will automatically enqueue failed events and evaluate them per the queue's configuration.

Parameters:

processingGroup - A String specifying the name of the processing group to register the given SequencedDeadLetterQueue for.

queueBuilder - A builder method returning a SequencedDeadLetterQueue based on a Configuration. The outcome is used by the given processingGroup to enqueue and evaluate failed events in.

Returns:

The current EventProcessingConfigurer instance, for fluent interfacing.

registerDefaultDeadLetterPolicy

default EventProcessingConfigurer registerDefaultDeadLetterPolicy(@Nonnull
 Function<Configuration,EnqueuePolicy<EventMessage<?>>> policyBuilder)

Register a default dead letter policy for any processing group using a dead letter queue. The processing group uses the policy to deduce whether a failed EventMessage should be enqueued for later evaluation.

Note that the configured component will not be used if the processing group does not have a dead letter queue.

Parameters:

policyBuilder - A builder method to construct a default dead letter policy.

Returns:

The current EventProcessingConfigurer instance, for fluent interfacing.

registerDeadLetterPolicy

default EventProcessingConfigurer registerDeadLetterPolicy(@Nonnull
 String processingGroup,
 @Nonnull
 Function<Configuration,EnqueuePolicy<EventMessage<?>>> policyBuilder)

Register a dead letter policy for the given processingGroup using a dead letter queue. The processing group uses the policy to deduce whether a failed EventMessage should be enqueued for later evaluation.

Note that the configured component will not be used if the processing group does not have a dead letter queue.

Parameters:

processingGroup - The name of the processing group to build an EnqueuePolicy for.

policyBuilder - A builder method to construct a dead letter policy for the given processingGroup.

Returns:

The current EventProcessingConfigurer instance, for fluent interfacing.

registerDeadLetteringEventHandlerInvokerConfiguration

default EventProcessingConfigurer registerDeadLetteringEventHandlerInvokerConfiguration(@Nonnull
 String processingGroup,
 @Nonnull
 EventProcessingConfigurer.DeadLetteringInvokerConfiguration configuration)

Register a EventProcessingConfigurer.DeadLetteringInvokerConfiguration for the given processingGroup. This configuration object allows for fine-grained customization of a dead lettering processing group through its builder.

Note that the configured component will not be used if the processing group does not have a dead letter queue.

Parameters:

processingGroup - The name of the processing group to attach additional configuration too.

configuration - The additional configuration for the dead lettering processing group.

Returns:

The current EventProcessingConfigurer instance, for fluent interfacing.

registerDeadLetterQueueProvider

default EventProcessingConfigurer registerDeadLetterQueueProvider(Function<String,Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>>> deadLetterQueueProvider)

Register the given deadLetterProvider as a default to build a SequencedDeadLetterQueue for EventProcessors created in this configuration.

The deadLetterProvider might return null if the given processing group name should not have a sequenced dead letter queue. An explicitly sequenced dead letter queue set using registerDeadLetterQueue(String, Function) will always have precedence over the one provided by this method.

Parameters:

deadLetterQueueProvider - a builder Function that provides a SequencedDeadLetterQueue for a processing group. It's possible to return null depending on the processing group.

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

usingSubscribingEventProcessors

default EventProcessingConfigurer usingSubscribingEventProcessors(EventProcessingConfigurer.SubscribableMessageSourceDefinitionBuilder builder)

If this method is invoked, Subscribing Event Processors will be created for all processing groups if none was explicitly provided.

Parameters:

builder - a function that creates SubscribableMessageSourceDefinition for given processing group name.

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing