org.axonframework.boot.autoconfig

Class AxonAutoConfiguration

java.lang.Object

org.axonframework.boot.autoconfig.AxonAutoConfiguration

All Implemented Interfaces:

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

@Configuration
 @EnableConfigurationProperties(value={EventProcessorProperties.class,DistributedCommandBusProperties.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)

Method Summary

Modifier and Type	Method and Description
SimpleCommandBus	commandBus(TransactionManager txManager, AxonConfiguration axonConfiguration)
CommandGateway	commandGateway(CommandBus commandBus)
void	configureEventHandling(EventHandlingConfiguration eventHandlingConfiguration, org.springframework.context.ApplicationContext applicationContext)
SimpleEventBus	eventBus(AxonConfiguration configuration)
EmbeddedEventStore	eventStore(EventStorageEngine storageEngine, AxonConfiguration configuration)
CorrelationDataProvider	messageOriginProvider()
SimpleQueryBus	queryBus(AxonConfiguration axonConfiguration, TransactionManager transactionManager)
SimpleQueryBus	queryBus(AxonConfiguration axonConfiguration, TransactionManager transactionManager, QueryInvocationErrorHandler eh)
XStreamSerializer	serializer()
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)

Method Detail

serializer

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

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)

eventBus

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

configureEventHandling

@Autowired
public void configureEventHandling(EventHandlingConfiguration eventHandlingConfiguration,
                                               org.springframework.context.ApplicationContext applicationContext)

commandBus

@ConditionalOnMissingBean(ignored=DistributedCommandBus.class,
                          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