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,TagsConfigurationProperties.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, TagsConfigurationProperties tagsConfigurationProperties, org.springframework.context.ApplicationContext applicationContext)

Method Summary

Modifier and Type	Method and Description
SpringAggregateSnapshotter	aggregateSnapshotter(Configuration configuration, HandlerDefinition handlerDefinition, ParameterResolverFactory parameterResolverFactory, EventStore eventStore, TransactionManager transactionManager, SpanFactory spanFactory)
SimpleCommandBus	commandBus(TransactionManager txManager, Configuration axonConfiguration, DuplicateCommandHandlerResolver duplicateCommandHandlerResolver)
CommandGateway	commandGateway(CommandBus commandBus)
void	configureEventHandling(EventProcessingConfigurer eventProcessingConfigurer, org.springframework.context.ApplicationContext applicationContext)
DuplicateCommandHandlerResolver	duplicateCommandHandlerResolver()
SimpleEventBus	eventBus(Configuration configuration)
EventGateway	eventGateway(EventBus eventBus)
Serializer	eventSerializer(Serializer messageSerializer, Serializer generalSerializer, RevisionResolver revisionResolver)
EmbeddedEventStore	eventStore(EventStorageEngine storageEngine, Configuration configuration)
CorrelationDataProvider	messageOriginProvider()
Serializer	messageSerializer(Serializer genericSerializer, RevisionResolver revisionResolver)
SimpleQueryBus	queryBus(Configuration axonConfiguration, TransactionManager transactionManager)
QueryGateway	queryGateway(QueryBus queryBus)
QueryUpdateEmitter	queryUpdateEmitter(Configuration configuration)
RevisionResolver	revisionResolver()
Serializer	serializer(RevisionResolver revisionResolver)
ConfigurerModule	serializerConfigurer(Serializer eventSerializer, Serializer messageSerializer, Serializer generalSerializer)
void	setBeanClassLoader(ClassLoader classLoader)
TagsConfiguration	tagsConfiguration()

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,
                             TagsConfigurationProperties tagsConfigurationProperties,
                             org.springframework.context.ApplicationContext applicationContext)

Method Detail

tagsConfiguration

@Bean
public TagsConfiguration tagsConfiguration()

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)

serializerConfigurer

@Bean
public ConfigurerModule serializerConfigurer(@Qualifier(value="eventSerializer")
                                                   Serializer eventSerializer,
                                                   @Qualifier(value="messageSerializer")
                                                   Serializer messageSerializer,
                                                   Serializer generalSerializer)

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,
                                                                                                                                                                                                 Configuration 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(Configuration configuration)

eventGateway

@ConditionalOnMissingBean
 @Bean
public EventGateway eventGateway(EventBus eventBus)

aggregateSnapshotter

@ConditionalOnMissingBean(value=Snapshotter.class)
 @ConditionalOnBean(value=EventStore.class)
 @Bean
public SpringAggregateSnapshotter aggregateSnapshotter(Configuration configuration,
                                                                                                                                                             HandlerDefinition handlerDefinition,
                                                                                                                                                             ParameterResolverFactory parameterResolverFactory,
                                                                                                                                                             EventStore eventStore,
                                                                                                                                                             TransactionManager transactionManager,
                                                                                                                                                             SpanFactory spanFactory)

configureEventHandling

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

duplicateCommandHandlerResolver

@Bean
 @ConditionalOnMissingBean
public DuplicateCommandHandlerResolver duplicateCommandHandlerResolver()

commandBus

@ConditionalOnMissingBean(ignoredType={"org.axonframework.commandhandling.distributed.DistributedCommandBus","org.axonframework.axonserver.connector.command.AxonServerCommandBus","org.axonframework.extensions.multitenancy.components.commandhandeling.MultiTenantCommandBus"},
                          value=CommandBus.class)
 @Qualifier(value="localSegment")
 @Bean
public SimpleCommandBus commandBus(TransactionManager txManager,
                                                                                                                                                                                                                                                                                                                                                                                                                 Configuration axonConfiguration,
                                                                                                                                                                                                                                                                                                                                                                                                                 DuplicateCommandHandlerResolver duplicateCommandHandlerResolver)

queryBus

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

queryUpdateEmitter

@Bean
public QueryUpdateEmitter queryUpdateEmitter(Configuration configuration)

setBeanClassLoader

public void setBeanClassLoader(@Nonnull
                               ClassLoader classLoader)

Specified by:

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