Package org.axonframework.config

Class EventProcessingModule

java.lang.Object

org.axonframework.config.EventProcessingModule

All Implemented Interfaces:

EventProcessingConfiguration, EventProcessingConfigurer, ModuleConfiguration

public class EventProcessingModule
extends Object
implements ModuleConfiguration, EventProcessingConfiguration, EventProcessingConfigurer

Event processing module configuration. Registers all configuration components within itself, builds the EventProcessingConfiguration and takes care of module lifecycle.

Since:

4.0

Author:

Milan Savic

Nested Class Summary

Nested classes/interfaces inherited from interface org.axonframework.config.EventProcessingConfigurer

EventProcessingConfigurer.DeadLetteringInvokerConfiguration, EventProcessingConfigurer.EventProcessorBuilder, EventProcessingConfigurer.PooledStreamingProcessorConfiguration, EventProcessingConfigurer.SubscribableMessageSourceDefinitionBuilder

Field Summary

Fields

Modifier and Type	Field	Description
protected Configuration	configuration
protected final Map<String,DeadLetteringEventHandlerInvoker>	deadLetteringEventHandlerInvokers
protected final Map<String,EventProcessingConfigurer.DeadLetteringInvokerConfiguration>	deadLetteringInvokerConfigs
protected final Map<String,Component<EnqueuePolicy<EventMessage<?>>>>	deadLetterPolicies
protected Function<String,Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>>>	deadLetterQueueProvider
protected final Map<String,Component<SequencedDeadLetterQueue<EventMessage<?>>>>	deadLetterQueues
protected final List<BiFunction<Configuration,String,MessageHandlerInterceptor<? super EventMessage<?>>>>	defaultHandlerInterceptors
protected final Map<String,Component<ErrorHandler>>	errorHandlers
protected final Map<String,Component<EventProcessor>>	eventProcessors
protected final Map<String,List<Function<Configuration,MessageHandlerInterceptor<? super EventMessage<?>>>>>	handlerInterceptorsBuilders
protected final Map<String,Component<ListenerInvocationErrorHandler>>	listenerInvocationErrorHandlers
protected final Map<String,MessageMonitorFactory>	messageMonitorFactories
protected final Map<String,EventProcessingConfigurer.PooledStreamingProcessorConfiguration>	psepConfigs
protected final Map<String,Component<RollbackConfiguration>>	rollbackConfigurations
protected final Map<String,Component<SequencingPolicy<? super EventMessage<?>>>>	sequencingPolicies
protected final Map<String,Component<TrackingEventProcessorConfiguration>>	tepConfigs
protected final Map<String,Component<TokenStore>>	tokenStore
protected final Map<String,Component<TransactionManager>>	transactionManagers

Constructor Summary

Constructors

Constructor	Description
EventProcessingModule()

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.
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.
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.
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.
Optional<EnqueuePolicy<EventMessage<?>>>	deadLetterPolicy(String processingGroup)	Returns the dead letter policy tied to the given processingGroup in an Optional.
Optional<SequencedDeadLetterQueue<EventMessage<?>>>	deadLetterQueue(String processingGroup)	Returns the SequencedDeadLetterQueue tied to the given processingGroup in an Optional.
ErrorHandler	errorHandler(String processorName)	Returns the ErrorHandler tied to the given processorName.
<T extends EventProcessor> Optional<T>	eventProcessorByProcessingGroup(String processingGroup)	Obtains an EventProcessor by it's processingGroup.
Map<String,EventProcessor>	eventProcessors()	Obtains all registered EventProcessors.
void	initialize(Configuration configuration)	Initialize the module configuration using the given global config.
List<MessageHandlerInterceptor<? super EventMessage<?>>>	interceptorsFor(String processorName)	Returns a List of MessageHandlerInterceptors for a processor with given processorName.
ListenerInvocationErrorHandler	listenerInvocationErrorHandler(String processingGroup)	Returns the ListenerInvocationErrorHandler tied to the given processingGroup.
MessageMonitor<? super Message<?>>	messageMonitor(Class<?> componentType, String eventProcessorName)	Returns the MessageMonitor set to the given componentType and componentName registered within this configuration.
protected static String	packageOfObject(Object object)	Gets the package name from the class of the given object.
protected EventProcessor	pooledStreamingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, Configuration config, StreamableMessageSource<TrackedEventMessage<?>> messageSource, EventProcessingConfigurer.PooledStreamingProcessorConfiguration processorConfiguration)	Default PooledStreamingEventProcessor configuration based on this configure module.
EventProcessingConfigurer	registerDeadLetteringEventHandlerInvokerConfiguration(String processingGroup, EventProcessingConfigurer.DeadLetteringInvokerConfiguration configuration)	Register a EventProcessingConfigurer.DeadLetteringInvokerConfiguration for the given processingGroup.
EventProcessingConfigurer	registerDeadLetterPolicy(String processingGroup, Function<Configuration,EnqueuePolicy<EventMessage<?>>> policyBuilder)	Register a dead letter policy for the given processingGroup using a dead letter queue.
EventProcessingConfigurer	registerDeadLetterQueue(String processingGroup, Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>> queueBuilder)	Register a SequencedDeadLetterQueue for the given processingGroup.
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.
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 EventProcessingConfigurer.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.
EventProcessingConfigurer	registerMessageMonitorFactory(String eventProcessorName, MessageMonitorFactory messageMonitorFactory)	Registers the factory to create the MessageMonitor for a EventProcessor of the given name.
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.
<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.
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> tokenStore)	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.
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.
RollbackConfiguration	rollbackConfiguration(String processorName)	Returns the RollbackConfiguration tied to the given processorName.
List<SagaConfiguration<?>>	sagaConfigurations()	Returns a List of SagaConfigurations registered within this configuration.
String	sagaProcessingGroup(Class<?> sagaType)	Gets the processing group for given sagaType.
SagaStore	sagaStore()	Returns a SagaStore registered within this configuration.
Optional<SequencedDeadLetterProcessor<EventMessage<?>>>	sequencedDeadLetterProcessor(String processingGroup)	Returns the SequencedDeadLetterProcessor tied to the given processingGroup in an Optional.
SequencingPolicy<? super EventMessage<?>>	sequencingPolicy(String processingGroup)	Returns the SequencingPolicy tied to the given processingGroup.
protected EventProcessor	subscribingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, SubscribableMessageSource<? extends EventMessage<?>> messageSource)	Default SubscribingEventProcessor configuration based on this configure module.
TokenStore	tokenStore(String processorName)	Returns the TokenStore tied to the given processorName.
protected EventProcessor	trackingEventProcessor(String name, EventHandlerInvoker eventHandlerInvoker, TrackingEventProcessorConfiguration config, StreamableMessageSource<TrackedEventMessage<?>> source)	Default TrackingEventProcessor configuration based on this configure module.
TransactionManager	transactionManager(String processorName)	Returns the TransactionManager tied to the given processorName.
EventProcessingConfigurer	usingPooledStreamingEventProcessors()	Defaults Event Processors builders to use PooledStreamingEventProcessor.
EventProcessingConfigurer	usingSubscribingEventProcessors()	Defaults Event Processors builders to use SubscribingEventProcessor.
EventProcessingConfigurer	usingSubscribingEventProcessors(EventProcessingConfigurer.SubscribableMessageSourceDefinitionBuilder defaultSource)	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.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.axonframework.config.EventProcessingConfiguration

eventProcessor, eventProcessor, eventProcessorByProcessingGroup, sagaConfiguration, sagaEventProcessor

Methods inherited from interface org.axonframework.config.EventProcessingConfigurer

assignHandlerInstancesMatching, assignHandlerTypesMatching, byDefaultAssignTo, registerMessageMonitor, registerPooledStreamingEventProcessor, registerPooledStreamingEventProcessor, registerSaga, registerSubscribingEventProcessor, registerTrackingEventProcessor, usingPooledStreamingEventProcessors

Methods inherited from interface org.axonframework.config.ModuleConfiguration

isType, phase, shutdown, start, unwrap

Field Details

eventProcessors

protected final Map<String,Component<EventProcessor>> eventProcessors

deadLetteringEventHandlerInvokers

protected final Map<String,DeadLetteringEventHandlerInvoker> deadLetteringEventHandlerInvokers

defaultHandlerInterceptors

protected final List<BiFunction<Configuration,String,MessageHandlerInterceptor<? super EventMessage<?>>>> defaultHandlerInterceptors

handlerInterceptorsBuilders

protected final Map<String,List<Function<Configuration,MessageHandlerInterceptor<? super EventMessage<?>>>>> handlerInterceptorsBuilders

listenerInvocationErrorHandlers

protected final Map<String,Component<ListenerInvocationErrorHandler>> listenerInvocationErrorHandlers

errorHandlers

protected final Map<String,Component<ErrorHandler>> errorHandlers

sequencingPolicies

protected final Map<String,Component<SequencingPolicy<? super EventMessage<?>>>> sequencingPolicies

messageMonitorFactories

protected final Map<String,MessageMonitorFactory> messageMonitorFactories

tokenStore

protected final Map<String,Component<TokenStore>> tokenStore

rollbackConfigurations

protected final Map<String,Component<RollbackConfiguration>> rollbackConfigurations

transactionManagers

protected final Map<String,Component<TransactionManager>> transactionManagers

deadLetterQueues

protected final Map<String,Component<SequencedDeadLetterQueue<EventMessage<?>>>> deadLetterQueues

deadLetterPolicies

protected final Map<String,Component<EnqueuePolicy<EventMessage<?>>>> deadLetterPolicies

tepConfigs

protected final Map<String,Component<TrackingEventProcessorConfiguration>> tepConfigs

psepConfigs

protected final Map<String,EventProcessingConfigurer.PooledStreamingProcessorConfiguration> psepConfigs

deadLetteringInvokerConfigs

protected final Map<String,EventProcessingConfigurer.DeadLetteringInvokerConfiguration> deadLetteringInvokerConfigs

deadLetterQueueProvider

protected Function<String,Function<Configuration,SequencedDeadLetterQueue<EventMessage<?>>>> deadLetterQueueProvider

configuration

protected Configuration configuration

Constructor Details

EventProcessingModule

public EventProcessingModule()

Method Details

initialize

public void initialize(Configuration configuration)

Description copied from interface: ModuleConfiguration

Initialize the module configuration using the given global config. Any specific start up or shut down processes should be added here by using the provided config and invoke LifecycleOperations.onStart(int, LifecycleHandler) and LifecycleOperations.onShutdown(int, LifecycleHandler) respectively.

Specified by:

initialize in interface ModuleConfiguration

Parameters:

configuration - the global configuration, providing access to generic components

eventProcessorByProcessingGroup

public <T extends EventProcessor> Optional<T> eventProcessorByProcessingGroup(String processingGroup)

Description copied from interface: EventProcessingConfiguration

Obtains an EventProcessor by it's processingGroup.

Specified by:

eventProcessorByProcessingGroup in interface EventProcessingConfiguration

Type Parameters:

T - the type of the expected EventProcessor

Parameters:

processingGroup - a String specifying the processing group of an EventProcessor

Returns:

an Optional referencing the EventProcessor

eventProcessors

public Map<String,EventProcessor> eventProcessors()

Description copied from interface: EventProcessingConfiguration

Obtains all registered EventProcessors.

Specified by:

eventProcessors in interface EventProcessingConfiguration

Returns:

a Map of registered EventProcessors within this configuration with the processor names as keys

sagaProcessingGroup

public String sagaProcessingGroup(Class<?> sagaType)

Description copied from interface: EventProcessingConfiguration

Gets the processing group for given sagaType.

Specified by:

sagaProcessingGroup in interface EventProcessingConfiguration

Parameters:

sagaType - the type of Saga

Returns:

the processing group

interceptorsFor

public List<MessageHandlerInterceptor<? super EventMessage<?>>> interceptorsFor(String processorName)

Description copied from interface: EventProcessingConfiguration

Returns a List of MessageHandlerInterceptors for a processor with given processorName.

Specified by:

interceptorsFor in interface EventProcessingConfiguration

Parameters:

processorName - a String specifying a processing group

Returns:

a List of MessageHandlerInterceptors for a processor with given processorName

listenerInvocationErrorHandler

public ListenerInvocationErrorHandler listenerInvocationErrorHandler(String processingGroup)

Description copied from interface: EventProcessingConfiguration

Returns the ListenerInvocationErrorHandler tied to the given processingGroup.

Specified by:

listenerInvocationErrorHandler in interface EventProcessingConfiguration

Parameters:

processingGroup - a String specifying a processing group

Returns:

the ListenerInvocationErrorHandler belonging to the given processingGroup

sequencingPolicy

public SequencingPolicy<? super EventMessage<?>> sequencingPolicy(String processingGroup)

Description copied from interface: EventProcessingConfiguration

Returns the SequencingPolicy tied to the given processingGroup.

Specified by:

sequencingPolicy in interface EventProcessingConfiguration

Parameters:

processingGroup - a String specifying a processing group

Returns:

the SequencingPolicy belonging to the given processingGroup

rollbackConfiguration

public RollbackConfiguration rollbackConfiguration(String processorName)

Description copied from interface: EventProcessingConfiguration

Returns the RollbackConfiguration tied to the given processorName.

Specified by:

rollbackConfiguration in interface EventProcessingConfiguration

Parameters:

processorName - a String specifying a processing group

Returns:

the RollbackConfiguration belonging to the given processorName

errorHandler

public ErrorHandler errorHandler(String processorName)

Description copied from interface: EventProcessingConfiguration

Returns the ErrorHandler tied to the given processorName.

Specified by:

errorHandler in interface EventProcessingConfiguration

Parameters:

processorName - a String specifying a processing group

Returns:

the ErrorHandler belonging to the given processorName

sagaStore

public SagaStore sagaStore()

Description copied from interface: EventProcessingConfiguration

Returns a SagaStore registered within this configuration.

Specified by:

sagaStore in interface EventProcessingConfiguration

Returns:

a SagaStore registered within this configuration

sagaConfigurations

public List<SagaConfiguration<?>> sagaConfigurations()

Description copied from interface: EventProcessingConfiguration

Returns a List of SagaConfigurations registered within this configuration.

Specified by:

sagaConfigurations in interface EventProcessingConfiguration

Returns:

a List of SagaConfigurations registered within this configuration

messageMonitor

public MessageMonitor<? super Message<?>> messageMonitor(Class<?> componentType,
 String eventProcessorName)

Description copied from interface: EventProcessingConfiguration

Returns the MessageMonitor set to the given componentType and componentName registered within this configuration.

Specified by:

messageMonitor in interface EventProcessingConfiguration

Parameters:

componentType - a Class type of component to be monitored

eventProcessorName - a String specifying the name of the component to be monitored

Returns:

the MessageMonitor registered to the given componentType and componentName

tokenStore

public TokenStore tokenStore(String processorName)

Description copied from interface: EventProcessingConfiguration

Returns the TokenStore tied to the given processorName.

Specified by:

tokenStore in interface EventProcessingConfiguration

Parameters:

processorName - a String specifying a event processor

Returns:

the TokenStore belonging to the given processorName

transactionManager

public TransactionManager transactionManager(String processorName)

Description copied from interface: EventProcessingConfiguration

Returns the TransactionManager tied to the given processorName.

Specified by:

transactionManager in interface EventProcessingConfiguration

Parameters:

processorName - a String specifying a processing group

Returns:

the TransactionManagerbelonging to the given processorName

deadLetterQueue

public Optional<SequencedDeadLetterQueue<EventMessage<?>>> deadLetterQueue(@Nonnull
 String processingGroup)

Description copied from interface: EventProcessingConfiguration

Returns the SequencedDeadLetterQueue tied to the given processingGroup in an Optional. May return an empty optional when there's no SequencedDeadLetterQueue present for the given processingGroup.

Specified by:

deadLetterQueue in interface EventProcessingConfiguration

Parameters:

processingGroup - The name of the processing group for which to return a SequencedDeadLetterQueue.

Returns:

The SequencedDeadLetterQueue tied to the given processingGroup, Optional.empty() if there is none.

deadLetterPolicy

public Optional<EnqueuePolicy<EventMessage<?>>> deadLetterPolicy(@Nonnull
 String processingGroup)

Description copied from interface: EventProcessingConfiguration

Returns the dead letter policy tied to the given processingGroup in an Optional. May return an Optional containing the default policy if present.

Specified by:

deadLetterPolicy in interface EventProcessingConfiguration

Parameters:

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

Returns:

The EnqueuePolicy belonging to the given processingGroup.

sequencedDeadLetterProcessor

public Optional<SequencedDeadLetterProcessor<EventMessage<?>>> sequencedDeadLetterProcessor(@Nonnull
 String processingGroup)

Description copied from interface: EventProcessingConfiguration

Returns the SequencedDeadLetterProcessor tied to the given processingGroup in an Optional. Returns an empty optional when the processingGroup does not have a SequencedDeadLetterQueue attached to it.

Specified by:

sequencedDeadLetterProcessor in interface EventProcessingConfiguration

Parameters:

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

Returns:

The SequencedDeadLetterProcessor tied to the given processingGroup in an Optional, Optional.empty() if there is none.

registerSaga

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

Description copied from interface: EventProcessingConfigurer

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

Specified by:

registerSaga in interface EventProcessingConfigurer

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

public EventProcessingConfigurer registerSagaStore(Function<Configuration,SagaStore> sagaStoreBuilder)

Description copied from interface: EventProcessingConfigurer

Registers a Function that builds a SagaStore.

Specified by:

registerSagaStore in interface EventProcessingConfigurer

Parameters:

sagaStoreBuilder - a Function that builds a SagaStore

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerEventHandler

public EventProcessingConfigurer registerEventHandler(Function<Configuration,Object> eventHandlerBuilder)

Description copied from interface: EventProcessingConfigurer

Registers a Function that builds an Event Handler instance.

Specified by:

registerEventHandler in interface EventProcessingConfigurer

Parameters:

eventHandlerBuilder - a Function that builds an Event Handler instance

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerDefaultListenerInvocationErrorHandler

public EventProcessingConfigurer registerDefaultListenerInvocationErrorHandler(Function<Configuration,ListenerInvocationErrorHandler> listenerInvocationErrorHandlerBuilder)

Description copied from interface: EventProcessingConfigurer

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

Specified by:

registerDefaultListenerInvocationErrorHandler in interface EventProcessingConfigurer

Parameters:

listenerInvocationErrorHandlerBuilder - a Function that builds the default ListenerInvocationErrorHandler

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerListenerInvocationErrorHandler

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

Description copied from interface: EventProcessingConfigurer

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

Specified by:

registerListenerInvocationErrorHandler in interface EventProcessingConfigurer

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

configureDefaultStreamableMessageSource

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

Description copied from interface: EventProcessingConfigurer

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 EventProcessingConfigurer.usingSubscribingEventProcessors() or EventProcessingConfigurer.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.

Specified by:

configureDefaultStreamableMessageSource in interface EventProcessingConfigurer

Parameters:

defaultSource - a Function that defines the Message source to use

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

configureDefaultSubscribableMessageSource

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

Description copied from interface: EventProcessingConfigurer

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 EventProcessingConfigurer.usingSubscribingEventProcessors() or EventProcessingConfigurer.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.

Specified by:

configureDefaultSubscribableMessageSource in interface EventProcessingConfigurer

Parameters:

defaultSource - a Function that defines the Message source to use

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerTrackingEventProcessor

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

Description copied from interface: EventProcessingConfigurer

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

Specified by:

registerTrackingEventProcessor in interface EventProcessingConfigurer

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

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

Description copied from interface: EventProcessingConfigurer

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

Specified by:

registerTrackingEventProcessor in interface EventProcessingConfigurer

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

public EventProcessingConfigurer registerEventProcessorFactory(EventProcessingConfigurer.EventProcessorBuilder eventProcessorBuilder)

Description copied from interface: EventProcessingConfigurer

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.

Specified by:

registerEventProcessorFactory in interface EventProcessingConfigurer

Parameters:

eventProcessorBuilder - a Function that builds an EventProcessor

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerEventProcessor

public EventProcessingConfigurer registerEventProcessor(String name,
 EventProcessingConfigurer.EventProcessorBuilder eventProcessorBuilder)

Description copied from interface: EventProcessingConfigurer

Registers an EventProcessingConfigurer.EventProcessorBuilder for the given processor name.

Specified by:

registerEventProcessor in interface EventProcessingConfigurer

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

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

Description copied from interface: EventProcessingConfigurer

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

Specified by:

registerTokenStore in interface EventProcessingConfigurer

Parameters:

processorName - a String specifying the name of a event processor

tokenStore - a Function that builds a TokenStore

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerTokenStore

public EventProcessingConfigurer registerTokenStore(Function<Configuration,TokenStore> tokenStore)

Description copied from interface: EventProcessingConfigurer

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

Specified by:

registerTokenStore in interface EventProcessingConfigurer

Parameters:

tokenStore - a Function that builds a TokenStore

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

usingSubscribingEventProcessors

public EventProcessingConfigurer usingSubscribingEventProcessors()

Description copied from interface: EventProcessingConfigurer

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.

Specified by:

usingSubscribingEventProcessors in interface EventProcessingConfigurer

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

usingTrackingEventProcessors

public EventProcessingConfigurer usingTrackingEventProcessors()

Description copied from interface: EventProcessingConfigurer

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.

Specified by:

usingTrackingEventProcessors in interface EventProcessingConfigurer

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

usingPooledStreamingEventProcessors

public EventProcessingConfigurer usingPooledStreamingEventProcessors()

Description copied from interface: EventProcessingConfigurer

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.

Specified by:

usingPooledStreamingEventProcessors in interface EventProcessingConfigurer

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerSubscribingEventProcessor

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

Description copied from interface: EventProcessingConfigurer

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

Specified by:

registerSubscribingEventProcessor in interface EventProcessingConfigurer

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

public EventProcessingConfigurer registerDefaultErrorHandler(Function<Configuration,ErrorHandler> errorHandlerBuilder)

Description copied from interface: EventProcessingConfigurer

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

Specified by:

registerDefaultErrorHandler in interface EventProcessingConfigurer

Parameters:

errorHandlerBuilder - a Function that builds an ErrorHandler

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerErrorHandler

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

Description copied from interface: EventProcessingConfigurer

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

Specified by:

registerErrorHandler in interface EventProcessingConfigurer

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

byDefaultAssignHandlerInstancesTo

public EventProcessingConfigurer byDefaultAssignHandlerInstancesTo(Function<Object,String> assignmentFunction)

Description copied from interface: EventProcessingConfigurer

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.

Specified by:

byDefaultAssignHandlerInstancesTo in interface EventProcessingConfigurer

Parameters:

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

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

byDefaultAssignHandlerTypesTo

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

Description copied from interface: EventProcessingConfigurer

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.

Specified by:

byDefaultAssignHandlerTypesTo in interface EventProcessingConfigurer

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

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

Description copied from interface: EventProcessingConfigurer

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.

Specified by:

assignHandlerInstancesMatching in interface EventProcessingConfigurer

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

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

Description copied from interface: EventProcessingConfigurer

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.

Specified by:

assignHandlerTypesMatching in interface EventProcessingConfigurer

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

public EventProcessingConfigurer assignProcessingGroup(String processingGroup,
 String processorName)

Description copied from interface: EventProcessingConfigurer

Defines a mapping for assigning processing groups to processors.

Specified by:

assignProcessingGroup in interface EventProcessingConfigurer

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

public EventProcessingConfigurer assignProcessingGroup(Function<String,String> assignmentRule)

Description copied from interface: EventProcessingConfigurer

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

Specified by:

assignProcessingGroup in interface EventProcessingConfigurer

Parameters:

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

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

See Also:

• EventProcessingConfigurer.assignProcessingGroup(String, String)

registerHandlerInterceptor

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

Description copied from interface: EventProcessingConfigurer

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.

Specified by:

registerHandlerInterceptor in interface EventProcessingConfigurer

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

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

Description copied from interface: EventProcessingConfigurer

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.

Specified by:

registerDefaultHandlerInterceptor in interface EventProcessingConfigurer

Parameters:

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

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerSequencingPolicy

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

Description copied from interface: EventProcessingConfigurer

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.

Specified by:

registerSequencingPolicy in interface EventProcessingConfigurer

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

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

Description copied from interface: EventProcessingConfigurer

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

Defaults to a SequentialPerAggregatePolicy.

Specified by:

registerDefaultSequencingPolicy in interface EventProcessingConfigurer

Parameters:

policyBuilder - a builder Function to create the SequencingPolicy to use

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerMessageMonitorFactory

public EventProcessingConfigurer registerMessageMonitorFactory(String eventProcessorName,
 MessageMonitorFactory messageMonitorFactory)

Description copied from interface: EventProcessingConfigurer

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

Specified by:

registerMessageMonitorFactory in interface EventProcessingConfigurer

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

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

Description copied from interface: EventProcessingConfigurer

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

Specified by:

registerRollbackConfiguration in interface EventProcessingConfigurer

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

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

Description copied from interface: EventProcessingConfigurer

Registers a TransactionManager for a EventProcessor of the given name.

Specified by:

registerTransactionManager in interface EventProcessingConfigurer

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

public EventProcessingConfigurer registerDefaultTransactionManager(Function<Configuration,TransactionManager> transactionManagerBuilder)

Description copied from interface: EventProcessingConfigurer

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

Specified by:

registerDefaultTransactionManager in interface EventProcessingConfigurer

Parameters:

transactionManagerBuilder - a Function that builds a TransactionManager

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerTrackingEventProcessorConfiguration

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

Description copied from interface: EventProcessingConfigurer

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

Specified by:

registerTrackingEventProcessorConfiguration in interface EventProcessingConfigurer

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

public EventProcessingConfigurer registerTrackingEventProcessorConfiguration(Function<Configuration,TrackingEventProcessorConfiguration> trackingEventProcessorConfigurationBuilder)

Description copied from interface: EventProcessingConfigurer

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

Specified by:

registerTrackingEventProcessorConfiguration in interface EventProcessingConfigurer

Parameters:

trackingEventProcessorConfigurationBuilder - a Function that builds a TrackingEventProcessorConfiguration

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerPooledStreamingEventProcessor

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

Description copied from interface: EventProcessingConfigurer

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 EventProcessingConfigurer.registerPooledStreamingEventProcessorConfiguration(PooledStreamingProcessorConfiguration) and EventProcessingConfigurer.registerPooledStreamingEventProcessorConfiguration(String, PooledStreamingProcessorConfiguration).

Specified by:

registerPooledStreamingEventProcessor in interface EventProcessingConfigurer

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

public EventProcessingConfigurer registerPooledStreamingEventProcessorConfiguration(String name,
 EventProcessingConfigurer.PooledStreamingProcessorConfiguration pooledStreamingProcessorConfiguration)

Description copied from interface: EventProcessingConfigurer

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

Specified by:

registerPooledStreamingEventProcessorConfiguration in interface EventProcessingConfigurer

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

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

Description copied from interface: EventProcessingConfigurer

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

Specified by:

registerDeadLetterQueue in interface EventProcessingConfigurer

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

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

Description copied from interface: EventProcessingConfigurer

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.

Specified by:

registerDefaultDeadLetterPolicy in interface EventProcessingConfigurer

Parameters:

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

Returns:

The current EventProcessingConfigurer instance, for fluent interfacing.

registerDeadLetterPolicy

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

Description copied from interface: EventProcessingConfigurer

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.

Specified by:

registerDeadLetterPolicy in interface EventProcessingConfigurer

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

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

Description copied from interface: EventProcessingConfigurer

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.

Specified by:

registerDeadLetteringEventHandlerInvokerConfiguration in interface EventProcessingConfigurer

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.

registerPooledStreamingEventProcessorConfiguration

public EventProcessingConfigurer registerPooledStreamingEventProcessorConfiguration(EventProcessingConfigurer.PooledStreamingProcessorConfiguration pooledStreamingProcessorConfiguration)

Description copied from interface: EventProcessingConfigurer

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

Specified by:

registerPooledStreamingEventProcessorConfiguration in interface EventProcessingConfigurer

Parameters:

pooledStreamingProcessorConfiguration - configuration used when constructing every PooledStreamingEventProcessor

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing

registerDeadLetterQueueProvider

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

Description copied from interface: EventProcessingConfigurer

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 EventProcessingConfigurer.registerDeadLetterQueue(String, Function) will always have precedence over the one provided by this method.

Specified by:

registerDeadLetterQueueProvider in interface EventProcessingConfigurer

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

subscribingEventProcessor

protected EventProcessor subscribingEventProcessor(String name,
 EventHandlerInvoker eventHandlerInvoker,
 SubscribableMessageSource<? extends EventMessage<?>> messageSource)

Default SubscribingEventProcessor configuration based on this configure module.

Parameters:

name - of the processor

eventHandlerInvoker - used by the processor for the vent handling

messageSource - where to retrieve events from

Returns:

Default SubscribingEventProcessor configuration based on this configure module.

trackingEventProcessor

protected EventProcessor trackingEventProcessor(String name,
 EventHandlerInvoker eventHandlerInvoker,
 TrackingEventProcessorConfiguration config,
 StreamableMessageSource<TrackedEventMessage<?>> source)

Default TrackingEventProcessor configuration based on this configure module.

Parameters:

name - of the processor

eventHandlerInvoker - used by the processor for the event handling

config - for the tracking event processor construction

source - where to retrieve events from

Returns:

Default TrackingEventProcessor configuration based on this configure module.

pooledStreamingEventProcessor

protected EventProcessor pooledStreamingEventProcessor(String name,
 EventHandlerInvoker eventHandlerInvoker,
 Configuration config,
 StreamableMessageSource<TrackedEventMessage<?>> messageSource,
 EventProcessingConfigurer.PooledStreamingProcessorConfiguration processorConfiguration)

Default PooledStreamingEventProcessor configuration based on this configure module.

Parameters:

name - of the processor

eventHandlerInvoker - used by the processor for the event handling

config - main configuration providing access for Axon components

messageSource - where to retrieve events from

processorConfiguration - for the pooled event processor construction

Returns:

Default PooledStreamingEventProcessor configuration based on this configure module.

packageOfObject

protected static String packageOfObject(Object object)

Gets the package name from the class of the given object.

Since class.getPackage() can be null e.g. for generated classes, the package name is determined the old fashioned way based on the full qualified class name.

Parameters:

object - Object

Returns:

String

usingSubscribingEventProcessors

public EventProcessingConfigurer usingSubscribingEventProcessors(EventProcessingConfigurer.SubscribableMessageSourceDefinitionBuilder defaultSource)

Description copied from interface: EventProcessingConfigurer

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

Specified by:

usingSubscribingEventProcessors in interface EventProcessingConfigurer

Parameters:

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

Returns:

the current EventProcessingConfigurer instance, for fluent interfacing