org.axonframework.springboot.autoconfig

Class AxonServerAutoConfiguration

java.lang.Object

org.axonframework.springboot.autoconfig.AxonServerAutoConfiguration

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

@AutoConfiguration
 @AutoConfigureBefore(value=AxonAutoConfiguration.class)
 @ConditionalOnClass(value=AxonServerConfiguration.class)
 @EnableConfigurationProperties(value=TagsConfigurationProperties.class)
 @ConditionalOnProperty(name="axon.axonserver.enabled",
                       matchIfMissing=true)
public class AxonServerAutoConfiguration
extends Object
implements org.springframework.context.ApplicationContextAware

Configures Axon Server as implementation for the CommandBus, QueryBus and EventStore.

Since:

4.0

Author:

Marc Gathier

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AxonServerAutoConfiguration.ConnectionDetailsConnectionManagerConfiguration
static class	AxonServerAutoConfiguration.DefaultConnectionManagerConfiguration

Constructor Summary

Constructors

Constructor and Description
AxonServerAutoConfiguration()

Method Summary

Modifier and Type	Method and Description
ConfigurerModule	autoPersistentStreamMessageSourceDefinitionBuilder(PersistentStreamScheduledExecutorBuilder executorBuilder, PersistentStreamMessageSourceFactory psFactory, AxonServerConfiguration axonServerConfiguration) Creates a ConfigurerModule to invoke EventProcessingConfigurer::usingSubscribingEventProcessors
AxonServerConfiguration	axonServerConfiguration()
PersistentStreamScheduledExecutorBuilder	backwardsCompatiblePersistentStreamScheduledExecutorBuilder(ScheduledExecutorService persistentStreamScheduler) Creates a PersistentStreamScheduledExecutorBuilder defaulting to the same given persistentStreamScheduler on each invocation.
CommandLoadFactorProvider	commandLoadFactorProvider(AxonServerConfiguration configuration)
CommandPriorityCalculator	commandPriorityCalculator()
EventScheduler	eventScheduler(Serializer eventSerializer, AxonServerConnectionManager connectionManager)
ManagedChannelCustomizer	managedChannelCustomizer()
PersistentStreamMessageSourceFactory	persistentStreamMessageSourceFactory() Creates a bean of type PersistentStreamMessageSourceFactory if one is not already defined.
ConfigurerModule	persistentStreamProcessorsConfigurerModule(EventProcessorProperties processorProperties, AxonServerConfiguration axonServerConfiguration) Creates a ConfigurerModule to configure sequencing policies for persistent streams connected to subscribing event processors with a dead letter queue.
PersistentStreamMessageSourceRegistrar	persistentStreamRegistrar(org.springframework.core.env.Environment environment, PersistentStreamScheduledExecutorBuilder executorBuilder) Constructs a PersistentStreamMessageSourceRegistrar to create and register Spring beans for persistent streams.
PersistentStreamScheduledExecutorBuilder	persistentStreamScheduledExecutorBuilder() Creates a PersistentStreamScheduledExecutorBuilder that constructs ScheduledExecutorServices for each persistent stream.
EventProcessorInfoConfiguration	processorInfoConfiguration(EventProcessingConfiguration eventProcessingConfiguration, AxonServerConnectionManager connectionManager, AxonServerConfiguration configuration)
QueryInvocationErrorHandler	queryInvocationErrorHandler()
QueryPriorityCalculator	queryPriorityCalculator()
RoutingStrategy	routingStrategy()
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
TargetContextResolver<Message<?>>	targetContextResolver()
ConfigurerModule	topologyChangeListenerConfigurerModule(AxonServerConnectionManager platformConnectionManager, List<TopologyChangeListener> changeListeners)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AxonServerAutoConfiguration

public AxonServerAutoConfiguration()

Method Detail

axonServerConfiguration

@Bean
public AxonServerConfiguration axonServerConfiguration()

managedChannelCustomizer

@Bean
 @ConditionalOnMissingBean
public ManagedChannelCustomizer managedChannelCustomizer()

routingStrategy

@Bean
 @ConditionalOnMissingBean
public RoutingStrategy routingStrategy()

commandPriorityCalculator

@Bean
 @ConditionalOnMissingBean
public CommandPriorityCalculator commandPriorityCalculator()

commandLoadFactorProvider

@Bean
 @ConditionalOnMissingBean
public CommandLoadFactorProvider commandLoadFactorProvider(AxonServerConfiguration configuration)

queryPriorityCalculator

@Bean
 @ConditionalOnMissingBean
public QueryPriorityCalculator queryPriorityCalculator()

queryInvocationErrorHandler

@Bean
 @ConditionalOnMissingBean
public QueryInvocationErrorHandler queryInvocationErrorHandler()

targetContextResolver

@ConditionalOnMissingBean
 @Bean
public TargetContextResolver<Message<?>> targetContextResolver()

processorInfoConfiguration

@Bean
 @ConditionalOnMissingClass(value="org.axonframework.extensions.multitenancy.autoconfig.MultiTenancyAxonServerAutoConfiguration")
public EventProcessorInfoConfiguration processorInfoConfiguration(EventProcessingConfiguration eventProcessingConfiguration,
                                                                                                                                                                                                          AxonServerConnectionManager connectionManager,
                                                                                                                                                                                                          AxonServerConfiguration configuration)

eventScheduler

@Bean
 @ConditionalOnMissingBean
 @ConditionalOnProperty(name="axon.axonserver.event-store.enabled",
                       matchIfMissing=true)
public EventScheduler eventScheduler(@Qualifier(value="eventSerializer")
                                                                                                                                                                                      Serializer eventSerializer,
                                                                                                                                                                                      AxonServerConnectionManager connectionManager)

persistentStreamScheduledExecutorBuilder

@Bean
 @ConditionalOnMissingBean
 @ConditionalOnMissingQualifiedBean(beanClass=java.util.concurrent.ScheduledExecutorService.class,
                                   qualifier="persistentStreamScheduler")
 @ConditionalOnProperty(name="axon.axonserver.event-store.enabled",
                       matchIfMissing=true)
public PersistentStreamScheduledExecutorBuilder persistentStreamScheduledExecutorBuilder()

Creates a PersistentStreamScheduledExecutorBuilder that constructs ScheduledExecutorServices for each persistent stream. Defaults to a PersistentStreamScheduledExecutorBuilder.defaultFactory().

Returns:

The a PersistentStreamScheduledExecutorBuilder that constructs ScheduledExecutorServices for each persistent stream.

backwardsCompatiblePersistentStreamScheduledExecutorBuilder

@Bean
 @ConditionalOnMissingBean
 @ConditionalOnQualifiedBean(beanClass=java.util.concurrent.ScheduledExecutorService.class,
                            qualifier="persistentStreamScheduler")
 @ConditionalOnProperty(name="axon.axonserver.event-store.enabled",
                       matchIfMissing=true)
public PersistentStreamScheduledExecutorBuilder backwardsCompatiblePersistentStreamScheduledExecutorBuilder(@Qualifier(value="persistentStreamScheduler")
                                                                                                                                                                                                                                                                                                                                                                                                                            ScheduledExecutorService persistentStreamScheduler)

Creates a PersistentStreamScheduledExecutorBuilder defaulting to the same given persistentStreamScheduler on each invocation. This bean-creation method is in place for backwards compatibility with 4.10.0, which defaulted to this behavior based on a bean of type ScheduledExecutorService with qualified persistentStreamScheduler.

persistentStreamRegistrar

@Bean
 @ConditionalOnProperty(name="axon.axonserver.event-store.enabled",
                       matchIfMissing=true)
public PersistentStreamMessageSourceRegistrar persistentStreamRegistrar(org.springframework.core.env.Environment environment,
                                                                                                                                                                                              PersistentStreamScheduledExecutorBuilder executorBuilder)

Constructs a PersistentStreamMessageSourceRegistrar to create and register Spring beans for persistent streams.

Parameters:

environment - The Spring Environment.

executorBuilder - The PersistentStreamScheduledExecutorBuilder used to construct a ScheduledExecutorService to perform the persistent stream's tasks with.

Returns:

The PersistentStreamMessageSourceRegistrar to create and register Spring beans for persistent streams.

autoPersistentStreamMessageSourceDefinitionBuilder

@Bean
 @ConditionalOnProperty(name="axon.axonserver.auto-persistent-streams-enable")
public ConfigurerModule autoPersistentStreamMessageSourceDefinitionBuilder(PersistentStreamScheduledExecutorBuilder executorBuilder,
                                                                                                                                                                PersistentStreamMessageSourceFactory psFactory,
                                                                                                                                                                AxonServerConfiguration axonServerConfiguration)

Creates a ConfigurerModule to invoke EventProcessingConfigurer::usingSubscribingEventProcessors

Parameters:

executorBuilder - The ScheduledExecutorService builder used during construction of the PersistentStreamMessageSourceDefinition.

psFactory - used during construction of the PersistentStreamMessageSourceDefinition.

axonServerConfiguration - Contains the persistent stream settings.

Returns:

A ConfigurerModule to configure

persistentStreamMessageSourceFactory

@Bean
 @ConditionalOnMissingBean
public PersistentStreamMessageSourceFactory persistentStreamMessageSourceFactory()

Creates a bean of type PersistentStreamMessageSourceFactory if one is not already defined. This factory is used to create instances of the PersistentStreamMessageSource with specified configurations.

The returned factory creates a new PersistentStreamMessageSource with the following parameters:

• name: The name of the persistent stream.
• configuration: The Axon framework configuration.
• persistentStreamProperties: Properties of the persistent stream.
• scheduler: The ScheduledExecutorService for scheduling tasks.
• batchSize: The number of events to fetch in a single batch.
• context: The context in which the persistent stream operates.

Returns:

A PersistentStreamMessageSourceFactory that constructs PersistentStreamMessageSource instances.

persistentStreamProcessorsConfigurerModule

@Bean
 @ConditionalOnProperty(name="axon.axonserver.event-store.enabled",
                       matchIfMissing=true)
public ConfigurerModule persistentStreamProcessorsConfigurerModule(EventProcessorProperties processorProperties,
                                                                                                                                                                                         AxonServerConfiguration axonServerConfiguration)

Creates a ConfigurerModule to configure sequencing policies for persistent streams connected to subscribing event processors with a dead letter queue.

Parameters:

processorProperties - Contains the configured event processors.

axonServerConfiguration - Contains the persistent stream definitions.

Returns:

A ConfigurerModule to configure sequencing policies for persistent streams connected to subscribing event processors with a dead letter queue.

topologyChangeListenerConfigurerModule

@Bean
 @ConditionalOnBean
public ConfigurerModule topologyChangeListenerConfigurerModule(AxonServerConnectionManager platformConnectionManager,
                                                                                         List<TopologyChangeListener> changeListeners)

setApplicationContext

public void setApplicationContext(@Nonnull
                                  org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException