Uses of Interface
org.axonframework.config.EventProcessingConfigurer

Packages that use EventProcessingConfigurer

Package	Description
org.axonframework.config
org.axonframework.spring.config
org.axonframework.springboot.autoconfig

Uses of EventProcessingConfigurer in org.axonframework.config

Classes in org.axonframework.config that implement EventProcessingConfigurer

Modifier and Type	Class	Description
class	EventProcessingModule	Event processing module configuration.

Methods in org.axonframework.config that return EventProcessingConfigurer

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

Method parameters in org.axonframework.config with type arguments of type EventProcessingConfigurer

Modifier and Type	Method	Description
default Configurer	Configurer.eventProcessing(Consumer<EventProcessingConfigurer> eventProcessingConfigurer)	Locates the EventProcessingConfigurer registered as a module with this Configurer and provides it to the given consumer for configuration.

Uses of EventProcessingConfigurer in org.axonframework.spring.config

Constructors in org.axonframework.spring.config with parameters of type EventProcessingConfigurer

Modifier	Constructor	Description
	EventHandlerRegistrar(AxonConfiguration axonConfiguration, ModuleConfiguration eventProcessingConfiguration, EventProcessingConfigurer eventProcessingConfigurer)	Deprecated. Initialize the registrar to register beans discovered with the given eventProcessing.

Uses of EventProcessingConfigurer in org.axonframework.springboot.autoconfig

Methods in org.axonframework.springboot.autoconfig with parameters of type EventProcessingConfigurer

Modifier and Type	Method	Description
void	AxonAutoConfiguration.configureEventHandling(EventProcessingConfigurer eventProcessingConfigurer, org.springframework.context.ApplicationContext applicationContext)
org.springframework.beans.factory.InitializingBean	InterceptorAutoConfiguration.messageHandlerInterceptorConfigurer(EventProcessingConfigurer eventProcessingConfigurer, Optional<List<MessageHandlerInterceptor<? super EventMessage<?>>>> interceptors)