Package | Description |
---|---|
org.axonframework.boot.autoconfig | |
org.axonframework.config | |
org.axonframework.spring.config |
Modifier and Type | Method and Description |
---|---|
void |
AxonAutoConfiguration.configureEventHandling(EventHandlingConfiguration eventHandlingConfiguration,
org.springframework.context.ApplicationContext applicationContext) |
Modifier and Type | Method and Description |
---|---|
EventHandlingConfiguration |
EventHandlingConfiguration.assignHandlersMatching(String name,
int priority,
Predicate<Object> criteria)
Configures a rule to assign Event Handler beans that match the given
criteria to the Event Processor
with given name , with given priority . |
EventHandlingConfiguration |
EventHandlingConfiguration.assignHandlersMatching(String name,
Predicate<Object> criteria)
Configures a rule to assign Event Handler beans that match the given
criteria to the Event Processor
with given name , with neutral priority (value 0). |
EventHandlingConfiguration |
EventHandlingConfiguration.byDefaultAssignTo(Function<Object,String> assignmentFunction)
Registers a function that defines the Event Processor name to assign Event Handler beans to when no other, more
explicit, rule matches and no
ProcessingGroup annotation is found. |
EventHandlingConfiguration |
EventHandlingConfiguration.byDefaultAssignTo(String name)
Registers the Event Processor name to assign Event Handler beans to when no other, more explicit, rule matches
and no
ProcessingGroup annotation is found. |
EventHandlingConfiguration |
EventHandlingConfiguration.configureMessageMonitor(String name,
Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder)
Configures the builder function to create the Message Monitor for the
EventProcessor of the given name. |
EventHandlingConfiguration |
EventHandlingConfiguration.configureMessageMonitor(String name,
MessageMonitorFactory messageMonitorFactory)
Configures the factory to create the Message Monitor for the
EventProcessor of the given name. |
EventHandlingConfiguration |
EventHandlingConfiguration.registerEventHandler(Function<Configuration,Object> eventHandlerBuilder)
Register an Event Handler Bean with this configuration.
|
EventHandlingConfiguration |
EventHandlingConfiguration.registerEventProcessor(String name,
EventHandlingConfiguration.EventProcessorBuilder eventProcessorBuilder)
Defines the Event Processor builder for an Event Processor with the given
name . |
EventHandlingConfiguration |
EventHandlingConfiguration.registerEventProcessorFactory(EventHandlingConfiguration.EventProcessorBuilder eventProcessorBuilder)
Allows for more fine-grained definition of the Event Processor to use for each group of Event Listeners.
|
EventHandlingConfiguration |
EventHandlingConfiguration.registerHandlerInterceptor(BiFunction<Configuration,String,MessageHandlerInterceptor<? super EventMessage<?>>> interceptorBuilder)
Register the given
interceptorBuilder to build an Message Handling Interceptor for Event Processors
created in this configuration. |
EventHandlingConfiguration |
EventHandlingConfiguration.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 . |
EventHandlingConfiguration |
EventHandlingConfiguration.registerSubscribingEventProcessor(String name)
Register a subscribing processor with given
name that subscribes to the Event Bus. |
EventHandlingConfiguration |
EventHandlingConfiguration.registerSubscribingEventProcessor(String name,
Function<Configuration,SubscribableMessageSource<? extends EventMessage<?>>> messageSource)
Register a subscribing processor with given
name that subscribes to the given messageSource . |
EventHandlingConfiguration |
EventHandlingConfiguration.registerTokenStore(String name,
Function<Configuration,TokenStore> tokenStore)
Register the TokenStore to use for a processor of given
name . |
EventHandlingConfiguration |
EventHandlingConfiguration.registerTrackingProcessor(String name)
Register a TrackingProcessor using default configuration for the given
name . |
EventHandlingConfiguration |
EventHandlingConfiguration.registerTrackingProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source)
Registers a TrackingProcessor using the given
source to read messages from. |
EventHandlingConfiguration |
EventHandlingConfiguration.registerTrackingProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source,
Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration,
Function<Configuration,SequencingPolicy<? super EventMessage<?>>> sequencingPolicy)
Registers a TrackingProcessor with the given
name , reading from the given source and using the
given processorConfiguration . |
EventHandlingConfiguration |
EventHandlingConfiguration.registerTrackingProcessor(String name,
Function<Configuration,TrackingEventProcessorConfiguration> processorConfiguration,
Function<Configuration,SequencingPolicy<? super EventMessage<?>>> sequencingPolicy)
Registers a TrackingProcessor with the given
name , reading from the Event Bus (or Store) from the main
configuration and using the given processorConfiguration . |
EventHandlingConfiguration |
EventHandlingConfiguration.usingTrackingProcessors()
Configure the use of Tracking Event Processors, instead of the default Subscribing ones.
|
EventHandlingConfiguration |
EventHandlingConfiguration.usingTrackingProcessors(Function<Configuration,TrackingEventProcessorConfiguration> config,
Function<Configuration,SequencingPolicy<? super EventMessage<?>>> sequencingPolicy)
Configure the use of Tracking Event Processors, instead of the default Subscribing ones.
|
Constructor and Description |
---|
EventHandlerRegistrar(AxonConfiguration axonConfiguration,
EventHandlingConfiguration eventHandlingConfiguration)
Initialize the registrar to register beans discovered with the given
eventHandlingConfiguration . |
Copyright © 2010–2017. All rights reserved.