Package | Description |
---|---|
org.axonframework.config | |
org.axonframework.spring.config | |
org.axonframework.springboot.autoconfig |
Modifier and Type | Class and Description |
---|---|
class |
EventProcessingModule
Event processing module configuration.
|
Modifier and Type | Method and 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 . |
EventProcessingConfigurer |
EventProcessingModule.assignHandlerInstancesMatching(String processingGroup,
int priority,
Predicate<Object> criteria) |
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 |
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 |
EventProcessingModule.assignHandlerTypesMatching(String processingGroup,
int priority,
Predicate<Class<?>> criteria) |
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 |
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(Function<String,String> assignmentRule) |
EventProcessingConfigurer |
EventProcessingConfigurer.assignProcessingGroup(String processingGroup,
String processorName)
Defines a mapping for assigning processing groups to processors.
|
EventProcessingConfigurer |
EventProcessingModule.assignProcessingGroup(String processingGroup,
String processorName) |
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 |
DefaultConfigurer.eventProcessing() |
EventProcessingConfigurer |
Configurer.eventProcessing()
Retrievee the
EventProcessingConfigurer registered as a module with this Configurer. |
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
EventProcessor s 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.registerErrorHandler(String eventProcessorName,
Function<Configuration,ErrorHandler> errorHandlerBuilder)
|
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)
|
EventProcessingConfigurer |
EventProcessingModule.registerListenerInvocationErrorHandler(String processingGroup,
Function<Configuration,ListenerInvocationErrorHandler> listenerInvocationErrorHandlerBuilder) |
default EventProcessingConfigurer |
EventProcessingConfigurer.registerMessageMonitor(String eventProcessorName,
Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder)
|
EventProcessingConfigurer |
EventProcessingConfigurer.registerMessageMonitorFactory(String eventProcessorName,
MessageMonitorFactory messageMonitorFactory)
|
EventProcessingConfigurer |
EventProcessingModule.registerMessageMonitorFactory(String eventProcessorName,
MessageMonitorFactory messageMonitorFactory) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerRollbackConfiguration(String name,
Function<Configuration,RollbackConfiguration> rollbackConfigurationBuilder)
|
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)
|
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)
|
EventProcessingConfigurer |
EventProcessingModule.registerSubscribingEventProcessor(String name,
Function<Configuration,SubscribableMessageSource<? extends EventMessage<?>>> messageSource) |
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(Function<Configuration,TokenStore> tokenStore) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerTokenStore(String processorName,
Function<Configuration,TokenStore> tokenStoreBuilder)
|
EventProcessingConfigurer |
EventProcessingModule.registerTokenStore(String processingGroup,
Function<Configuration,TokenStore> tokenStore) |
default EventProcessingConfigurer |
EventProcessingConfigurer.registerTrackingEventProcessor(String name)
Registers a
TrackingEventProcessor with given name within this
Configurer. |
default EventProcessingConfigurer |
EventProcessingConfigurer.registerTrackingEventProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source)
|
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,
Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration) |
EventProcessingConfigurer |
EventProcessingConfigurer.registerTransactionManager(String name,
Function<Configuration,TransactionManager> transactionManagerBuilder)
|
EventProcessingConfigurer |
EventProcessingModule.registerTransactionManager(String name,
Function<Configuration,TransactionManager> transactionManagerBuilder) |
EventProcessingConfigurer |
EventProcessingConfigurer.usingSubscribingEventProcessors()
Defaults Event Processors builders to use
SubscribingEventProcessor . |
EventProcessingConfigurer |
EventProcessingModule.usingSubscribingEventProcessors() |
Modifier and Type | Method and 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. |
Constructor and Description |
---|
EventHandlerRegistrar(AxonConfiguration axonConfiguration,
ModuleConfiguration eventProcessingConfiguration,
EventProcessingConfigurer eventProcessingConfigurer)
Initialize the registrar to register beans discovered with the given
eventProcessing . |
Modifier and Type | Method and Description |
---|---|
void |
AxonAutoConfiguration.configureEventHandling(EventProcessingConfigurer eventProcessingConfigurer,
org.springframework.context.ApplicationContext applicationContext) |
Copyright © 2010–2018. All rights reserved.