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 |
---|---|
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 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)
Configure 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)
Configure an Embedded Event Store which uses the given Event Storage Engine to store its events.
|
default Configurer |
Configurer.configureEventBus(Function<Configuration,EventBus> eventBusBuilder)
Configure the given Event Bus to use in this configuration.
|
default Configurer |
Configurer.configureEventStore(Function<Configuration,EventStore> eventStoreBuilder)
Configure the given Event Store to use in this configuration.
|
Configurer |
DefaultConfigurer.configureMessageMonitor(Function<Configuration,BiFunction<Class<?>,String,MessageMonitor<Message<?>>>> messageMonitorFactoryBuilder) |
Configurer |
Configurer.configureMessageMonitor(Function<Configuration,BiFunction<Class<?>,String,MessageMonitor<Message<?>>>> messageMonitorFactoryBuilder)
Configure the Message Monitor to use for the Message processing components 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)
Configure the given Resource Injector to use for Sagas in this configuration.
|
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)
Configure the given Serializer to use in this configuration.
|
default Configurer |
Configurer.configureTransactionManager(Function<Configuration,TransactionManager> transactionManagerBuilder)
Configure 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)
Register 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.
|
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 . |
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.registerTrackingProcessor(String name,
Function<Configuration,StreamableMessageSource<TrackedEventMessage<?>>> source)
Registers a TrackingProcessor using the given
source to read messages from. |
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.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.
|
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–2017. All rights reserved.