org.axonframework.springboot.autoconfig

Class AxonAutoConfiguration

java.lang.Object

org.axonframework.springboot.autoconfig.AxonAutoConfiguration

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanClassLoaderAware

@Configuration
 @AutoConfigureAfter(value=EventProcessingAutoConfiguration.class)
 @EnableConfigurationProperties(value={EventProcessorProperties.class,DistributedCommandBusProperties.class,SerializerProperties.class})
public class AxonAutoConfiguration
extends Object
implements org.springframework.beans.factory.BeanClassLoaderAware

Author:

Allard Buijze, Josh Long

Constructor Summary

Constructors

Constructor and Description
AxonAutoConfiguration(EventProcessorProperties eventProcessorProperties, SerializerProperties serializerProperties, org.springframework.context.ApplicationContext applicationContext)

Method Summary

Modifier and Type	Method and Description
SimpleCommandBus	commandBus(TransactionManager txManager, AxonConfiguration axonConfiguration)
CommandGateway	commandGateway(CommandBus commandBus)
void	configureEventHandling(EventProcessingConfigurer eventProcessingConfigurer, org.springframework.context.ApplicationContext applicationContext)
SimpleEventBus	eventBus(AxonConfiguration configuration)
Serializer	eventSerializer(Serializer messageSerializer, Serializer generalSerializer, RevisionResolver revisionResolver)
EmbeddedEventStore	eventStore(EventStorageEngine storageEngine, AxonConfiguration configuration)
CorrelationDataProvider	messageOriginProvider()
Serializer	messageSerializer(Serializer genericSerializer, RevisionResolver revisionResolver)
SimpleQueryBus	queryBus(AxonConfiguration axonConfiguration, TransactionManager transactionManager)
SimpleQueryBus	queryBus(AxonConfiguration axonConfiguration, TransactionManager transactionManager, QueryInvocationErrorHandler eh)
QueryGateway	queryGateway(QueryBus queryBus)
RevisionResolver	revisionResolver()
Serializer	serializer(RevisionResolver revisionResolver)
void	setBeanClassLoader(ClassLoader classLoader)

Methods inherited from class java.lang.Object

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

Constructor Detail

AxonAutoConfiguration

public AxonAutoConfiguration(EventProcessorProperties eventProcessorProperties,
                             SerializerProperties serializerProperties,
                             org.springframework.context.ApplicationContext applicationContext)

Method Detail

revisionResolver

@Bean
 @ConditionalOnMissingBean
public RevisionResolver revisionResolver()

serializer

@Bean
 @Primary
 @ConditionalOnMissingQualifiedBean(beanClass=Serializer.class,
                                   qualifier="!eventSerializer,messageSerializer")
public Serializer serializer(RevisionResolver revisionResolver)

messageSerializer

@Bean
 @Qualifier(value="messageSerializer")
 @ConditionalOnMissingQualifiedBean(beanClass=Serializer.class,
                                   qualifier="messageSerializer")
public Serializer messageSerializer(Serializer genericSerializer,
                                                                                                                                                                                                                   RevisionResolver revisionResolver)

eventSerializer

@Bean
 @Qualifier(value="eventSerializer")
 @ConditionalOnMissingQualifiedBean(beanClass=Serializer.class,
                                   qualifier="eventSerializer")
public Serializer eventSerializer(@Qualifier(value="messageSerializer")
                                                                                                                                                                                                             Serializer messageSerializer,
                                                                                                                                                                                                             Serializer generalSerializer,
                                                                                                                                                                                                             RevisionResolver revisionResolver)

messageOriginProvider

@Bean
 @ConditionalOnMissingBean
public CorrelationDataProvider messageOriginProvider()

eventStore

@Qualifier(value="eventStore")
 @Bean(name="eventBus")
 @ConditionalOnMissingBean(value=EventBus.class)
 @ConditionalOnBean(value=EventStorageEngine.class)
public EmbeddedEventStore eventStore(EventStorageEngine storageEngine,
                                                                                                                                                                                                 AxonConfiguration configuration)

commandGateway

@ConditionalOnMissingBean
 @Bean
public CommandGateway commandGateway(CommandBus commandBus)

queryGateway

@ConditionalOnMissingBean
 @Bean
public QueryGateway queryGateway(QueryBus queryBus)

eventBus

@Bean
 @ConditionalOnMissingBean(value={EventStorageEngine.class,EventBus.class})
public SimpleEventBus eventBus(AxonConfiguration configuration)

configureEventHandling

@Autowired
public void configureEventHandling(EventProcessingConfigurer eventProcessingConfigurer,
                                              org.springframework.context.ApplicationContext applicationContext)

commandBus

@ConditionalOnMissingBean(ignoredType={"org.axonframework.commandhandling.distributed.DistributedCommandBus","org.axonframework.axonserver.connector.command.AxonServerCommandBus"},
                          value=CommandBus.class)
 @Qualifier(value="localSegment")
 @Bean
public SimpleCommandBus commandBus(TransactionManager txManager,
                                                                                                                                                                                                                                                                                                                   AxonConfiguration axonConfiguration)

queryBus

@ConditionalOnMissingBean(value={QueryBus.class,QueryInvocationErrorHandler.class})
 @Qualifier(value="localSegment")
 @Bean
public SimpleQueryBus queryBus(AxonConfiguration axonConfiguration,
                                                                                                                                                            TransactionManager transactionManager)

queryBus

@ConditionalOnBean(value=QueryInvocationErrorHandler.class)
 @ConditionalOnMissingBean(value=QueryBus.class)
 @Qualifier(value="localSegment")
 @Bean
public SimpleQueryBus queryBus(AxonConfiguration axonConfiguration,
                                                                                                                                                                                     TransactionManager transactionManager,
                                                                                                                                                                                     QueryInvocationErrorHandler eh)

setBeanClassLoader

public void setBeanClassLoader(ClassLoader classLoader)

Specified by:

setBeanClassLoader in interface org.springframework.beans.factory.BeanClassLoaderAware