Package | Description |
---|---|
org.axonframework.boot.autoconfig | |
org.axonframework.config |
Modifier and Type | Method and Description |
---|---|
void |
AxonAutoConfiguration.configureEventHandling(EventHandlingConfiguration eventHandlingConfiguration,
EventProcessingConfiguration eventProcessingConfiguration,
org.springframework.context.ApplicationContext applicationContext) |
Modifier and Type | Method and Description |
---|---|
EventProcessingConfiguration |
EventProcessingConfiguration.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.
|
EventProcessingConfiguration |
EventProcessingConfiguration.assignProcessingGroup(String processingGroup,
String processorName)
Defines a mapping for assigning processing groups to processors.
|
EventProcessingConfiguration |
EventProcessingConfiguration.configureErrorHandler(Function<Configuration,ErrorHandler> errorHandlerBuilder)
Configures the default
ErrorHandler for any
EventProcessor . |
EventProcessingConfiguration |
EventProcessingConfiguration.configureErrorHandler(String name,
Function<Configuration,ErrorHandler> errorHandlerBuilder)
|
EventProcessingConfiguration |
EventProcessingConfiguration.configureMessageMonitor(String name,
Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder)
Configures the builder function to create the Message Monitor for the
EventProcessor of the given name. |
EventProcessingConfiguration |
EventProcessingConfiguration.configureMessageMonitor(String name,
MessageMonitorFactory messageMonitorFactory)
Configures the factory to create the Message Monitor for the
EventProcessor of the given name. |
EventProcessingConfiguration |
EventProcessingConfiguration.configureRollbackConfiguration(String name,
Function<Configuration,RollbackConfiguration> rollbackConfigurationBuilder)
|
EventProcessingConfiguration |
EventProcessingConfiguration.configureTransactionManager(String name,
Function<Configuration,TransactionManager> transactionManagerBuilder)
|
default EventProcessingConfiguration |
Configuration.eventProcessingConfiguration()
Returns the Event Processing Configuration in this Configuration.
|
EventProcessingConfiguration |
EventProcessingConfiguration.registerEventProcessor(String name,
EventProcessingConfiguration.EventProcessorBuilder eventProcessorBuilder)
Defines the Event Processor builder for an Event Processor with the given
name . |
EventProcessingConfiguration |
EventProcessingConfiguration.registerEventProcessorFactory(EventProcessingConfiguration.EventProcessorBuilder eventProcessorBuilder)
Allows for more fine-grained definition of the Event Processor to use for each group of Event Listeners.
|
EventProcessingConfiguration |
EventProcessingConfiguration.registerHandlerInterceptor(String processorName,
Function<Configuration,MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder)
Register the given
interceptorBuilder to build an Message Handling Interceptor for the Event Processor
with given processorName . |
EventProcessingConfiguration |
EventProcessingConfiguration.registerHandlerInvoker(String processingGroup,
Function<Configuration,EventHandlerInvoker> eventHandlerInvokerBuilder)
Registers handler invoker within this registry which will be assigned to the event processing group with given
processingGroup during the initialization phase. |
EventProcessingConfiguration |
EventProcessingConfiguration.registerSubscribingEventProcessor(String name)
Register a subscribing event processor with given
name that subscribes to the Event Bus. |
EventProcessingConfiguration |
EventProcessingConfiguration.registerSubscribingEventProcessor(String name,
Function<Configuration,SubscribableMessageSource<? extends EventMessage<?>>> messageSource)
Register a subscribing event processor with given
name that subscribes to the given messageSource . |
EventProcessingConfiguration |
EventProcessingConfiguration.registerTokenStore(String name,
Function<Configuration,TokenStore> tokenStore)
Register the TokenStore to use for a processor of given
name . |
EventProcessingConfiguration |
EventProcessingConfiguration.registerTrackingEventProcessor(String name)
Register a TrackingEventProcessor using default configuration for the given
name . |
EventProcessingConfiguration |
EventProcessingConfiguration.registerTrackingEventProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source,
Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration)
Registers a TrackingEventProcessor with the given
name , reading from the given source and using
the given processorConfiguration . |
EventProcessingConfiguration |
EventProcessingConfiguration.registerTrackingEventProcessor(String name,
Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration)
Registers a TrackingEventProcessor with the given
name , reading from the Event Bus (or Store) from the
main configuration and using the given processorConfiguration . |
EventProcessingConfiguration |
EventProcessingConfiguration.registerTrackingEventProcessorUsingSource(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source)
Registers a TrackingEventProcessor using the given
source to read messages from. |
EventProcessingConfiguration |
EventProcessingConfiguration.usingTrackingProcessors()
Configure the use of Tracking Event Processors, instead of the default Subscribing ones.
|
EventProcessingConfiguration |
EventProcessingConfiguration.usingTrackingProcessors(Function<Configuration,TrackingEventProcessorConfiguration> processorConfig)
Configure the use of Tracking Event Processors, instead of the default Subscribing ones.
|
Copyright © 2010–2018. All rights reserved.