Package | Description |
---|---|
org.axonframework.axonserver.connector.event.axon | |
org.axonframework.config | |
org.axonframework.spring.config |
Modifier and Type | Method and Description |
---|---|
void |
EventProcessorInfoConfiguration.initialize(Configuration config) |
Constructor and Description |
---|
EventProcessorInfoConfiguration(Function<Configuration,EventProcessingConfiguration> eventProcessingConfiguration,
Function<Configuration,AxonServerConnectionManager> connectionManager,
Function<Configuration,AxonServerConfiguration> axonServerConfiguration) |
EventProcessorInfoConfiguration(Function<Configuration,EventProcessingConfiguration> eventProcessingConfiguration,
Function<Configuration,AxonServerConnectionManager> connectionManager,
Function<Configuration,AxonServerConfiguration> axonServerConfiguration) |
EventProcessorInfoConfiguration(Function<Configuration,EventProcessingConfiguration> eventProcessingConfiguration,
Function<Configuration,AxonServerConnectionManager> connectionManager,
Function<Configuration,AxonServerConfiguration> axonServerConfiguration) |
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 |
EventProcessingConfigurer.EventProcessorBuilder.build(String name,
Configuration configuration,
EventHandlerInvoker eventHandlerInvoker)
|
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.
|
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 DeadlineManager |
DefaultConfigurer.defaultDeadlineManager(Configuration config)
Provides the default
DeadlineManager implementation. |
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 QueryUpdateEmitter |
DefaultConfigurer.defaultQueryUpdateEmitter(Configuration config)
Provides the default QueryUpdateEmitter implementation.
|
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.
|
SagaConfiguration<T> |
SagaConfigurer.initialize(Configuration configuration)
Initializes Saga Configuration by using the main
Configuration . |
void |
AggregateConfigurer.initialize(Configuration parent) |
void |
EventProcessingModule.initialize(Configuration configuration) |
void |
ModuleConfiguration.initialize(Configuration config)
Initialize the module configuration using the given global
config |
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.
|
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.
|
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.
|
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.
|
default Configurer |
Configurer.configureQueryUpdateEmitter(Function<Configuration,QueryUpdateEmitter> queryUpdateEmitterBuilder)
Configures the given Query Update Emitter 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.
|
SagaConfigurer<T> |
SagaConfigurer.configureRepository(Function<Configuration,SagaRepository<T>> repositoryBuilder)
Configures a
SagaRepository for this Saga. |
default Configurer |
Configurer.configureResourceInjector(Function<Configuration,ResourceInjector> resourceInjectorBuilder)
Configures the given Resource Injector to use for Sagas in this configuration.
|
SagaConfigurer<T> |
SagaConfigurer.configureSagaManager(Function<Configuration,AbstractSagaManager<T>> managerBuilder)
Configures a Saga Manager for this Saga.
|
SagaConfigurer<T> |
SagaConfigurer.configureSagaStore(Function<Configuration,SagaStore<? super T>> storeBuilder)
Configures a
SagaStore for this Saga. |
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.
|
default Configurer |
Configurer.configureTransactionManager(Function<Configuration,TransactionManager> transactionManagerBuilder)
Configures the given Transaction Manager to use in this configuration.
|
default Configurer |
Configurer.registerCommandHandler(Function<Configuration,Object> annotatedCommandHandlerBuilder)
Registers a command handler bean with this configuration.
|
Configurer |
DefaultConfigurer.registerCommandHandler(int phase,
Function<Configuration,Object> annotatedCommandHandlerBuilder) |
Configurer |
Configurer.registerCommandHandler(int phase,
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.
|
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 EventProcessingConfigurer.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) |
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
|
Configurer |
DefaultConfigurer.registerHandlerDefinition(BiFunction<Configuration,Class,HandlerDefinition> handlerDefinitionClass) |
Configurer |
Configurer.registerHandlerDefinition(BiFunction<Configuration,Class,HandlerDefinition> handlerDefinitionClass)
Registers the definition of a Handler class.
|
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)
|
default Configurer |
Configurer.registerQueryHandler(Function<Configuration,Object> annotatedQueryHandlerBuilder)
Registers a query handler bean with this configuration.
|
Configurer |
DefaultConfigurer.registerQueryHandler(int phase,
Function<Configuration,Object> annotatedQueryHandlerBuilder) |
Configurer |
Configurer.registerQueryHandler(int phase,
Function<Configuration,Object> annotatedQueryHandlerBuilder)
Registers a query handler bean with this configuration.
|
EventProcessingConfigurer |
EventProcessingConfigurer.registerRollbackConfiguration(String name,
Function<Configuration,RollbackConfiguration> rollbackConfigurationBuilder)
|
EventProcessingConfigurer |
EventProcessingModule.registerRollbackConfiguration(String name,
Function<Configuration,RollbackConfiguration> rollbackConfigurationBuilder) |
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) |
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,
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 |
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 |
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) |
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 . |
ConfigurationScopeAwareProvider(Configuration configuration)
Instantiate a lazy
ScopeAwareProvider with the given configuration parameter. |
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.