Package org.axonframework.springboot.autoconfig

Class AxonServerBusAutoConfiguration

java.lang.Object

org.axonframework.springboot.autoconfig.AxonServerBusAutoConfiguration

@AutoConfiguration
@AutoConfigureAfter(AxonServerAutoConfiguration.class)
@AutoConfigureBefore(AxonAutoConfiguration.class)
@ConditionalOnClass(AxonServerConfiguration.class)
@ConditionalOnProperty(name="axon.axonserver.enabled",
                       matchIfMissing=true)
public class AxonServerBusAutoConfiguration
extends Object

Configures Axon Server implementations of the CommandBus, EventStore, and QueryBus.

Since:

4.6.0

Author:

Marc Gathier, Stefan Dragisic

Constructor Summary

Constructors

Constructor	Description
AxonServerBusAutoConfiguration()

Method Summary

Modifier and Type	Method	Description
AxonServerCommandBus	axonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager, AxonServerConfiguration axonServerConfiguration, CommandBus localSegment, Serializer messageSerializer, RoutingStrategy routingStrategy, CommandPriorityCalculator priorityCalculator, CommandLoadFactorProvider loadFactorProvider, TargetContextResolver<? super CommandMessage<?>> targetContextResolver, CommandBusSpanFactory spanFactory)
AxonServerEventStoreFactory	axonServerEventStoreFactory(AxonServerConfiguration axonServerConfig, AxonServerConnectionManager axonServerConnectionManager, Serializer snapshotSerializer, Serializer eventSerializer, Configuration config)
EventStore	eventStore(AxonServerConfiguration axonServerConfiguration, Configuration configuration, AxonServerConnectionManager axonServerConnectionManager, Serializer snapshotSerializer, Serializer eventSerializer)
AxonServerQueryBus	queryBus(AxonServerConnectionManager axonServerConnectionManager, AxonServerConfiguration axonServerConfiguration, Configuration axonConfiguration, TransactionManager txManager, Serializer messageSerializer, Serializer genericSerializer, QueryPriorityCalculator priorityCalculator, QueryInvocationErrorHandler queryInvocationErrorHandler, TargetContextResolver<? super QueryMessage<?,?>> targetContextResolver)

Methods inherited from class java.lang.Object

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

Constructor Details

AxonServerBusAutoConfiguration

public AxonServerBusAutoConfiguration()

Method Details

axonServerCommandBus

@Bean
@Primary
@ConditionalOnMissingQualifiedBean(qualifier="!localSegment",
                                   beanClass=CommandBus.class)
public AxonServerCommandBus axonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager,
 AxonServerConfiguration axonServerConfiguration,
 @Qualifier("localSegment")
 CommandBus localSegment,
 @Qualifier("messageSerializer")
 Serializer messageSerializer,
 RoutingStrategy routingStrategy,
 CommandPriorityCalculator priorityCalculator,
 CommandLoadFactorProvider loadFactorProvider,
 TargetContextResolver<? super CommandMessage<?>> targetContextResolver,
 CommandBusSpanFactory spanFactory)

queryBus

@Bean
@ConditionalOnMissingBean(QueryBus.class)
public AxonServerQueryBus queryBus(AxonServerConnectionManager axonServerConnectionManager,
 AxonServerConfiguration axonServerConfiguration,
 Configuration axonConfiguration,
 TransactionManager txManager,
 @Qualifier("messageSerializer")
 Serializer messageSerializer,
 Serializer genericSerializer,
 QueryPriorityCalculator priorityCalculator,
 QueryInvocationErrorHandler queryInvocationErrorHandler,
 TargetContextResolver<? super QueryMessage<?,?>> targetContextResolver)

eventStore

@Bean
@ConditionalOnMissingBean
@ConditionalOnProperty(name="axon.axonserver.event-store.enabled",
                       matchIfMissing=true)
public EventStore eventStore(AxonServerConfiguration axonServerConfiguration,
 Configuration configuration,
 AxonServerConnectionManager axonServerConnectionManager,
 Serializer snapshotSerializer,
 @Qualifier("eventSerializer")
 Serializer eventSerializer)

axonServerEventStoreFactory

@Bean
@ConditionalOnMissingBean
@ConditionalOnProperty(name="axon.axonserver.event-store.enabled",
                       matchIfMissing=true)
public AxonServerEventStoreFactory axonServerEventStoreFactory(AxonServerConfiguration axonServerConfig,
 AxonServerConnectionManager axonServerConnectionManager,
 Serializer snapshotSerializer,
 @Qualifier("eventSerializer")
 Serializer eventSerializer,
 Configuration config)