| Package | Description | 
|---|---|
| org.axonframework.config | |
| org.axonframework.spring.config | 
| Modifier and Type | Method and Description | 
|---|---|
Configuration | 
DefaultConfigurer.buildConfiguration()  | 
Configuration | 
Configurer.buildConfiguration()
Returns the completely initialized Configuration built using this configurer. 
 | 
protected Configuration | 
DefaultConfigurer.getConfig()
Returns the current Configuration object being built by this Configurer, without initializing it. 
 | 
default Configuration | 
Configurer.start()
Builds the configuration and starts it immediately. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
MessageMonitor<Message<?>> | 
MessageMonitorFactory.create(Configuration configuration,
      Class<?> componentType,
      String componentName)
Function to create a Message Monitor based on the given configuration, component type and component name. 
 | 
EventProcessor | 
EventHandlingConfiguration.EventProcessorBuilder.createEventProcessor(Configuration configuration,
                    String name,
                    List<?> eventHandlers)
Builder function for an Event Processor. 
 | 
protected CommandBus | 
DefaultConfigurer.defaultCommandBus(Configuration config)
Provides the default CommandBus implementation. 
 | 
protected CommandGateway | 
DefaultConfigurer.defaultCommandGateway(Configuration config)
Returns a  
DefaultCommandGateway that will use the configuration's CommandBus to dispatch
 commands. | 
protected EventBus | 
DefaultConfigurer.defaultEventBus(Configuration config)
Provides the default EventBus implementation. 
 | 
protected ParameterResolverFactory | 
DefaultConfigurer.defaultParameterResolverFactory(Configuration config)
Provides the default ParameterResolverFactory. 
 | 
protected QueryBus | 
DefaultConfigurer.defaultQueryBus(Configuration config)
Provides the default QueryBus implementations. 
 | 
protected QueryGateway | 
DefaultConfigurer.defaultQueryGateway(Configuration config)
Returns a  
DefaultQueryGateway that will use the configuration's QueryBus to dispatch queries. | 
protected ResourceInjector | 
DefaultConfigurer.defaultResourceInjector(Configuration config)
Returns a  
ConfigurationResourceInjector that injects resources defined in the given config
 Configuration. | 
protected Serializer | 
DefaultConfigurer.defaultSerializer(Configuration config)
Provides the default Serializer implementation. 
 | 
void | 
SagaConfiguration.initialize(Configuration config)  | 
void | 
ModuleConfiguration.initialize(Configuration config)
Initialize the module configuration using the given global  
config | 
void | 
EventHandlingConfiguration.initialize(Configuration config)  | 
void | 
AggregateConfigurer.initialize(Configuration parent)  | 
List<MessageHandlerInterceptor<? super EventMessage<?>>> | 
EventHandlingConfiguration.interceptorsFor(Configuration configuration,
               String processorName)
Returns the list of Message Handler Interceptors registered for the given  
processorName. | 
| Modifier and Type | Method and Description | 
|---|---|
AggregateConfigurer<A> | 
AggregateConfigurer.configureAggregateFactory(Function<Configuration,AggregateFactory<A>> aggregateFactoryBuilder)
Defines the factory to use to to create new Aggregates instances of the type under configuration. 
 | 
default Configurer | 
Configurer.configureCommandBus(Function<Configuration,CommandBus> commandBusBuilder)
Configures the given Command Bus to use in this configuration. 
 | 
AggregateConfigurer<A> | 
AggregateConfigurer.configureCommandHandler(Function<Configuration,AggregateAnnotationCommandHandler> aggregateCommandHandlerBuilder)
Defines the AggregateAnnotationCommandHandler instance to use. 
 | 
AggregateConfigurer<A> | 
AggregateConfigurer.configureCommandTargetResolver(Function<Configuration,CommandTargetResolver> commandTargetResolverBuilder)
Defines the CommandTargetResolver to use for the Aggregate type under configuration. 
 | 
Configurer | 
DefaultConfigurer.configureCorrelationDataProviders(Function<Configuration,List<CorrelationDataProvider>> correlationDataProviderBuilder)  | 
Configurer | 
Configurer.configureCorrelationDataProviders(Function<Configuration,List<CorrelationDataProvider>> correlationDataProviderBuilder)
Configures the CorrelationDataProviders that Message processing components should use to attach correlation data
 to outgoing messages. 
 | 
Configurer | 
DefaultConfigurer.configureEmbeddedEventStore(Function<Configuration,EventStorageEngine> storageEngineBuilder)  | 
Configurer | 
Configurer.configureEmbeddedEventStore(Function<Configuration,EventStorageEngine> storageEngineBuilder)
Configures an Embedded Event Store which uses the given Event Storage Engine to store its events. 
 | 
SagaConfiguration<S> | 
SagaConfiguration.configureErrorHandler(Function<Configuration,ErrorHandler> errorHandler)
Configures the ErrorHandler to use when an error occurs processing an Event. 
 | 
EventHandlingConfiguration | 
EventHandlingConfiguration.configureErrorHandler(Function<Configuration,ErrorHandler> errorHandlerBuilder)
Configures the default  
ErrorHandler for any
 EventProcessor. | 
EventHandlingConfiguration | 
EventHandlingConfiguration.configureErrorHandler(String name,
                     Function<Configuration,ErrorHandler> errorHandlerBuilder)
 | 
default Configurer | 
Configurer.configureEventBus(Function<Configuration,EventBus> eventBusBuilder)
Configures the given Event Bus to use in this configuration. 
 | 
Configurer | 
DefaultConfigurer.configureEventSerializer(Function<Configuration,Serializer> eventSerializerBuilder)  | 
Configurer | 
Configurer.configureEventSerializer(Function<Configuration,Serializer> eventSerializerBuilder)
Configures the given event Serializer to use in this configuration. 
 | 
default Configurer | 
Configurer.configureEventStore(Function<Configuration,EventStore> eventStoreBuilder)
Configures the given Event Store to use in this configuration. 
 | 
SagaConfiguration<S> | 
SagaConfiguration.configureListenerInvocationErrorHandler(Function<Configuration,ListenerInvocationErrorHandler> listenerInvocationErrorHandler)
Configures the ListenerInvocationErrorHandler to use when processing of event in saga fails. 
 | 
EventHandlingConfiguration | 
EventHandlingConfiguration.configureListenerInvocationErrorHandler(Function<Configuration,ListenerInvocationErrorHandler> listenerInvocationErrorHandlerBuilder)
Configures the default  
ListenerInvocationErrorHandler for any
 EventProcessor. | 
EventHandlingConfiguration | 
EventHandlingConfiguration.configureListenerInvocationErrorHandler(String name,
                                       Function<Configuration,ListenerInvocationErrorHandler> listenerInvocationErrorHandlerBuilder)
 | 
default Configurer | 
Configurer.configureMessageMonitor(Class<?> componentType,
                       Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder)
Configures the builder function to create the Message Monitor for the Message processing components in this
 configuration that match the given componentType, unless more specific configuration based on both type and name
 is available. 
 | 
default Configurer | 
Configurer.configureMessageMonitor(Class<?> componentType,
                       String componentName,
                       Function<Configuration,MessageMonitor<Message<?>>> messageMonitorBuilder)
Configures the builder function to create the Message Monitor for the Message processing components in this
 configuration that match the given class and name. 
 | 
Configurer | 
DefaultConfigurer.configureMessageMonitor(Function<Configuration,BiFunction<Class<?>,String,MessageMonitor<Message<?>>>> builder)  | 
Configurer | 
Configurer.configureMessageMonitor(Function<Configuration,BiFunction<Class<?>,String,MessageMonitor<Message<?>>>> messageMonitorFactoryBuilder)
Configures the Message Monitor to use for the Message processing components in this configuration, unless more
 specific configuration based on the component's type, or type and name is available. 
 | 
SagaConfiguration<S> | 
SagaConfiguration.configureMessageMonitor(Function<Configuration,MessageMonitor<? super EventMessage<?>>> messageMonitor)
Configures a MessageMonitor to be used to monitor Events processed on by the Saga being configured. 
 | 
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. | 
Configurer | 
DefaultConfigurer.configureMessageSerializer(Function<Configuration,Serializer> messageSerializerBuilder)  | 
Configurer | 
Configurer.configureMessageSerializer(Function<Configuration,Serializer> messageSerializerBuilder)
Configures the given event Serializer to use in this configuration. 
 | 
default Configurer | 
Configurer.configureQueryBus(Function<Configuration,QueryBus> queryBusBuilder)
Configures the given Query Bus to use in this configuration. 
 | 
AggregateConfigurer<A> | 
AggregateConfigurer.configureRepository(Function<Configuration,Repository<A>> repositoryBuilder)
Defines the repository to use to load and store Aggregates of this type. 
 | 
default Configurer | 
Configurer.configureResourceInjector(Function<Configuration,ResourceInjector> resourceInjectorBuilder)
Configures the given Resource Injector to use for Sagas in this configuration. 
 | 
SagaConfiguration<S> | 
SagaConfiguration.configureRollbackConfiguration(Function<Configuration,RollbackConfiguration> rollbackConfiguration)
Defines the policy to roll back or commit a Unit of Work in case exceptions occur. 
 | 
SagaConfiguration<S> | 
SagaConfiguration.configureSagaStore(Function<Configuration,SagaStore<? super S>> sagaStoreBuilder)
Configures the Saga Store to use to store Saga instances of this type. 
 | 
default Configurer | 
Configurer.configureSerializer(Function<Configuration,Serializer> serializerBuilder)
Configures the given Serializer to use in this configuration. 
 | 
AggregateConfigurer<A> | 
AggregateConfigurer.configureSnapshotTrigger(Function<Configuration,SnapshotTriggerDefinition> snapshotTriggerDefinition)
Configures snapshotting for the Aggregate type under configuration. 
 | 
SagaConfiguration<S> | 
SagaConfiguration.configureTokenStore(Function<Configuration,TokenStore> tokenStore)
Registers the given  
tokenStore for use by a TrackingProcessor for the Saga being configured. | 
SagaConfiguration<S> | 
SagaConfiguration.configureTrackingProcessor(Function<Configuration,TrackingEventProcessorConfiguration> trackingEventProcessorConfiguration)
Registers the  
TrackingEventProcessorConfiguration to use when building the processor for this Saga type. | 
SagaConfiguration<S> | 
SagaConfiguration.configureTransactionManager(Function<Configuration,TransactionManager> transactionManager)
Defines the Transaction Manager to use when processing Events for this Saga. 
 | 
default Configurer | 
Configurer.configureTransactionManager(Function<Configuration,TransactionManager> transactionManagerBuilder)
Configures the given Transaction Manager to use in this configuration. 
 | 
Configurer | 
DefaultConfigurer.registerCommandHandler(Function<Configuration,Object> annotatedCommandHandlerBuilder)  | 
Configurer | 
Configurer.registerCommandHandler(Function<Configuration,Object> annotatedCommandHandlerBuilder)
Registers a command handler bean with this configuration. 
 | 
<C> Configurer | 
DefaultConfigurer.registerComponent(Class<C> componentType,
                 Function<Configuration,? extends C> componentBuilder)  | 
<C> Configurer | 
Configurer.registerComponent(Class<C> componentType,
                 Function<Configuration,? extends C> componentBuilder)
Registers a component which should be made available to other components or modules in this Configuration. 
 | 
EventHandlingConfiguration | 
EventHandlingConfiguration.registerEventHandler(Function<Configuration,Object> eventHandlerBuilder)
Register an Event Handler Bean with this configuration. 
 | 
Configurer | 
DefaultConfigurer.registerEventUpcaster(Function<Configuration,EventUpcaster> upcasterBuilder)  | 
Configurer | 
Configurer.registerEventUpcaster(Function<Configuration,EventUpcaster> upcasterBuilder)
Registers an upcaster to be used to upcast Events to a newer version 
 | 
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. | 
SagaConfiguration<S> | 
SagaConfiguration.registerHandlerInterceptor(Function<Configuration,MessageHandlerInterceptor<? super EventMessage<?>>> handlerInterceptorBuilder)
Registers the handler interceptor provided by the given  
handlerInterceptorBuilder function with
 the processor defined 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. | 
Configurer | 
DefaultConfigurer.registerQueryHandler(Function<Configuration,Object> annotatedQueryHandlerBuilder)  | 
Configurer | 
Configurer.registerQueryHandler(Function<Configuration,Object> annotatedQueryHandlerBuilder)
Registers a query handler bean with this configuration. 
 | 
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,
                         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,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,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.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. | 
static <S> SagaConfiguration<S> | 
SagaConfiguration.subscribingSagaManager(Class<S> sagaType,
                      Function<Configuration,SubscribableMessageSource<EventMessage<?>>> messageSourceBuilder)
Initialize a configuration for a Saga of given  
sagaType, using a Subscribing Event Processor to process
 incoming Events from the message source provided by given messageSourceBuilder | 
static <S> SagaConfiguration<S> | 
SagaConfiguration.subscribingSagaManager(Class<S> sagaType,
                      Function<Configuration,SubscribableMessageSource<EventMessage<?>>> messageSourceBuilder,
                      Function<Configuration,EventProcessingStrategy> eventProcessingStrategy)
Initialize a configuration for a Saga of given  
sagaType, using a Subscribing Event Processor to process
 incoming Events from the message source provided by given messageSourceBuilder. | 
static <S> SagaConfiguration<S> | 
SagaConfiguration.subscribingSagaManager(Class<S> sagaType,
                      Function<Configuration,SubscribableMessageSource<EventMessage<?>>> messageSourceBuilder,
                      Function<Configuration,EventProcessingStrategy> eventProcessingStrategy)
Initialize a configuration for a Saga of given  
sagaType, using a Subscribing Event Processor to process
 incoming Events from the message source provided by given messageSourceBuilder. | 
static <S> SagaConfiguration<S> | 
SagaConfiguration.trackingSagaManager(Class<S> sagaType,
                   Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> messageSourceBuilder)
Initialize a configuration for a Saga of given  
sagaType, using a Tracking Event Processor to process
 incoming Events from a Message Source provided by given messageSourceBuilder. | 
void | 
Component.update(Function<Configuration,? extends B> builderFunction)
Updates the builder function for this component. 
 | 
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. 
 | 
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 | 
|---|
Component(Configuration config,
         String name,
         Function<Configuration,? extends B> builderFunction)
Creates a component for the given  
config with given name created by the given
 builderFunction. | 
ConfigurationParameterResolverFactory(Configuration configuration)
Initialize an instance using given  
configuration to supply the value to resolve parameters with | 
ConfigurationResourceInjector(Configuration configuration)
Initializes the ResourceInjector to inject the resources found in the given  
configuration. | 
| Constructor and Description | 
|---|
Component(Configuration config,
         String name,
         Function<Configuration,? extends B> builderFunction)
Creates a component for the given  
config with given name created by the given
 builderFunction. | 
Component(Supplier<Configuration> config,
         String name,
         Function<Configuration,? extends B> builderFunction)
Creates a component for the given  
config with given name created by the given
 builderFunction. | 
Component(Supplier<Configuration> config,
         String name,
         Function<Configuration,? extends B> builderFunction)
Creates a component for the given  
config with given name created by the given
 builderFunction. | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AxonConfiguration
Spring Configuration class that defines a number of conditional beans. 
 | 
Copyright © 2010–2018. All rights reserved.