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)
public class AxonServerAutoConfiguration
extends Object
implements org.springframework.context.ApplicationContextAware

Configures AxonServer as implementation for the CommandBus and QueryBus

Author:

Marc Gathier

Constructor Summary

Constructors

Constructor and Description
AxonServerAutoConfiguration()

Method Summary

Modifier and Type	Method and Description
AxonServerConfiguration	axonServerConfiguration()
AxonServerCommandBus	commandBus(TransactionManager txManager, AxonConfiguration axonConfiguration, AxonServerConfiguration axonServerConfiguration, Serializer serializer, AxonServerConnectionManager axonServerConnectionManager, RoutingStrategy routingStrategy, CommandPriorityCalculator priorityCalculator)
CommandPriorityCalculator	commandPriorityCalculator()
EventStore	eventStore(AxonServerConfiguration axonServerConfiguration, AxonConfiguration configuration, AxonServerConnectionManager axonServerConnectionManager, Serializer snapshotSerializer, Serializer eventSerializer)
AxonServerConnectionManager	platformConnectionManager(AxonServerConfiguration routingConfiguration)
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)
QueryInvocationErrorHandler	queryInvocationErrorHandler()
QueryPriorityCalculator	queryPriorityCalculator()
RoutingStrategy	routingStrategy()
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)

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(destroyMethod="shutdown")
public AxonServerConnectionManager platformConnectionManager(AxonServerConfiguration routingConfiguration)

commandBus

@Bean(destroyMethod="disconnect")
 @Primary
 @ConditionalOnMissingBean(value=CommandBus.class)
public AxonServerCommandBus commandBus(TransactionManager txManager,
                                                                                                                                      AxonConfiguration axonConfiguration,
                                                                                                                                      AxonServerConfiguration axonServerConfiguration,
                                                                                                                                      Serializer serializer,
                                                                                                                                      AxonServerConnectionManager axonServerConnectionManager,
                                                                                                                                      RoutingStrategy routingStrategy,
                                                                                                                                      CommandPriorityCalculator priorityCalculator)

routingStrategy

@Bean
 @ConditionalOnMissingBean
public RoutingStrategy routingStrategy()

commandPriorityCalculator

@Bean
 @ConditionalOnMissingBean
public CommandPriorityCalculator commandPriorityCalculator()

queryPriorityCalculator

@Bean
 @ConditionalOnMissingBean
public QueryPriorityCalculator queryPriorityCalculator()

queryInvocationErrorHandler

@Bean
 @ConditionalOnMissingBean
public QueryInvocationErrorHandler queryInvocationErrorHandler()

queryBus

@Bean(destroyMethod="disconnect")
 @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)

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)