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

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

Method Detail

serializer

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

revisionResolver

@Bean
 @ConditionalOnMissingBean
public 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)

messageSerializer

@Bean
 @Qualifier(value="messageSerializer")
 @ConditionalOnMissingQualifiedBean(beanClass=Serializer.class,
                                   qualifier="messageSerializer")
public Serializer messageSerializer(Serializer genericSerializer,
                                                                                                                                                                                                                       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)

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