EventProcessingConfigurer (Axon Framework 4.3.5 API)

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 and Description

static interface EventProcessingConfigurer.EventProcessorBuilder
Contract which defines how to build an event processor.

Nested Classes
Modifier and Type	Interface and Description
`static interface`	`EventProcessingConfigurer.EventProcessorBuilder` Contract which defines how to build an event processor.

Method Summary

All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method and 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(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`	`assignProcessingGroup(String processingGroup, String processorName)` Defines a mapping for assigning processing groups to processors.
`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.
`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 `EventProcessor`s 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`	`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`.
`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(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.
`EventProcessingConfigurer`	`registerTokenStore(String processorName, Function<Configuration,TokenStore> tokenStoreBuilder)` Register a `Function` that builds a `TokenStore` for the given `processorName`.
`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(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`	`usingSubscribingEventProcessors()` Defaults Event Processors builders to use `SubscribingEventProcessor`.
`EventProcessingConfigurer`	`usingTrackingEventProcessors()` Defaults Event Processors builders to use `TrackingEventProcessor`.

- Method Detail
  - 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 defaul 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
  - 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
  - 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

Interface EventProcessingConfigurer

Nested Class Summary

Method Summary

Method Detail

registerSaga

registerSaga

registerSagaStore

registerEventHandler

registerDefaultListenerInvocationErrorHandler

registerListenerInvocationErrorHandler

registerTrackingEventProcessor

configureDefaultStreamableMessageSource

configureDefaultSubscribableMessageSource

registerTrackingEventProcessor

registerTrackingEventProcessor

registerEventProcessorFactory

registerEventProcessor

registerTokenStore

registerTokenStore

usingSubscribingEventProcessors

usingTrackingEventProcessors

registerSubscribingEventProcessor

registerSubscribingEventProcessor

registerDefaultErrorHandler

registerErrorHandler

byDefaultAssignTo

byDefaultAssignHandlerInstancesTo

byDefaultAssignHandlerTypesTo

assignHandlerInstancesMatching

assignHandlerTypesMatching

assignHandlerInstancesMatching

assignHandlerTypesMatching

assignProcessingGroup

assignProcessingGroup

registerHandlerInterceptor

registerDefaultHandlerInterceptor

registerSequencingPolicy

registerDefaultSequencingPolicy

registerMessageMonitor

registerMessageMonitorFactory

registerRollbackConfiguration

registerTransactionManager

registerTrackingEventProcessorConfiguration