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

@Configuration
 @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

Constructor Summary

Constructors

Constructor and Description
AxonServerAutoConfiguration()

Method Summary

Modifier and Type	Method and Description
AxonServerCommandBus	axonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager, AxonServerConfiguration axonServerConfiguration, CommandBus localSegment, Serializer messageSerializer, RoutingStrategy routingStrategy, CommandPriorityCalculator priorityCalculator, CommandLoadFactorProvider loadFactorProvider, TargetContextResolver<? super CommandMessage<?>> targetContextResolver)
AxonServerConfiguration	axonServerConfiguration()
CommandLoadFactorProvider	commandLoadFactorProvider(AxonServerConfiguration configuration)
CommandPriorityCalculator	commandPriorityCalculator()
EventScheduler	eventScheduler(Serializer eventSerializer, AxonServerConnectionManager connectionManager)
EventStore	eventStore(AxonServerConfiguration axonServerConfiguration, AxonConfiguration configuration, AxonServerConnectionManager axonServerConnectionManager, Serializer snapshotSerializer, Serializer eventSerializer)
AxonServerConnectionManager	platformConnectionManager(AxonServerConfiguration axonServerConfiguration, TagsConfigurationProperties tagsConfigurationProperties)
EventProcessorInfoConfiguration	processorInfoConfiguration(EventProcessingConfiguration eventProcessingConfiguration, AxonServerConnectionManager connectionManager, AxonServerConfiguration configuration)
AxonServerQueryBus	queryBus(AxonServerConnectionManager axonServerConnectionManager, AxonServerConfiguration axonServerConfiguration, AxonConfiguration axonConfiguration, TransactionManager txManager, Serializer messageSerializer, Serializer genericSerializer, QueryPriorityCalculator priorityCalculator, QueryInvocationErrorHandler queryInvocationErrorHandler, TargetContextResolver<? super QueryMessage<?,?>> targetContextResolver)
QueryInvocationErrorHandler	queryInvocationErrorHandler()
QueryPriorityCalculator	queryPriorityCalculator()
RoutingStrategy	routingStrategy()
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
TargetContextResolver<Message<?>>	targetContextResolver()

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

platformConnectionManager

@Bean
public AxonServerConnectionManager platformConnectionManager(AxonServerConfiguration axonServerConfiguration,
                                                                   TagsConfigurationProperties tagsConfigurationProperties)

axonServerCommandBus

@Bean
 @Primary
 @ConditionalOnMissingQualifiedBean(qualifier="!localSegment",
                                   beanClass=CommandBus.class)
public AxonServerCommandBus axonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager,
                                                                                                                                                                                               AxonServerConfiguration axonServerConfiguration,
                                                                                                                                                                                               @Qualifier(value="localSegment")
                                                                                                                                                                                               CommandBus localSegment,
                                                                                                                                                                                               @Qualifier(value="messageSerializer")
                                                                                                                                                                                               Serializer messageSerializer,
                                                                                                                                                                                               RoutingStrategy routingStrategy,
                                                                                                                                                                                               CommandPriorityCalculator priorityCalculator,
                                                                                                                                                                                               CommandLoadFactorProvider loadFactorProvider,
                                                                                                                                                                                               TargetContextResolver<? super CommandMessage<?>> targetContextResolver)

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

queryBus

@Bean
 @ConditionalOnMissingBean(value=QueryBus.class)
public AxonServerQueryBus queryBus(AxonServerConnectionManager axonServerConnectionManager,
                                                                                          AxonServerConfiguration axonServerConfiguration,
                                                                                          AxonConfiguration axonConfiguration,
                                                                                          TransactionManager txManager,
                                                                                          @Qualifier(value="messageSerializer")
                                                                                          Serializer messageSerializer,
                                                                                          Serializer genericSerializer,
                                                                                          QueryPriorityCalculator priorityCalculator,
                                                                                          QueryInvocationErrorHandler queryInvocationErrorHandler,
                                                                                          TargetContextResolver<? super QueryMessage<?,?>> targetContextResolver)

targetContextResolver

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

setApplicationContext

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

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

processorInfoConfiguration

@Bean
public EventProcessorInfoConfiguration processorInfoConfiguration(EventProcessingConfiguration eventProcessingConfiguration,
                                                                        AxonServerConnectionManager connectionManager,
                                                                        AxonServerConfiguration configuration)

eventStore

@Bean
 @ConditionalOnMissingBean
public EventStore eventStore(AxonServerConfiguration axonServerConfiguration,
                                                              AxonConfiguration configuration,
                                                              AxonServerConnectionManager axonServerConnectionManager,
                                                              Serializer snapshotSerializer,
                                                              @Qualifier(value="eventSerializer")
                                                              Serializer eventSerializer)

eventScheduler

@Bean
 @ConditionalOnMissingBean
public EventScheduler eventScheduler(@Qualifier(value="eventSerializer")
                                                                      Serializer eventSerializer,
                                                                      AxonServerConnectionManager connectionManager)