Package 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(AxonAutoConfiguration.class)
@ConditionalOnClass(AxonServerConfiguration.class)
@EnableConfigurationProperties(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	Description
static class	AxonServerAutoConfiguration.ConnectionDetailsConnectionManagerConfiguration
static class	AxonServerAutoConfiguration.DefaultConnectionManagerConfiguration

Constructor Summary

Constructors

Constructor	Description
AxonServerAutoConfiguration()

Method Summary

Modifier and Type	Method	Description
ConfigurerModule	autoPersistentStreamMessageSourceDefinitionBuilder(PersistentStreamScheduledExecutorBuilder executorBuilder, PersistentStreamMessageSourceFactory psFactory, AxonServerConfiguration axonServerConfiguration)	Creates a ConfigurerModule to invoke invalid @link {@link 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 Details

AxonServerAutoConfiguration

public AxonServerAutoConfiguration()

Method Details

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("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("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("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

invalid @link

{@link 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