@Configuration @AutoConfigureAfter(value=AxonServerAutoConfiguration.class) @AutoConfigureBefore(value=AxonAutoConfiguration.class) @ConditionalOnClass(value=AxonServerConfiguration.class) @ConditionalOnProperty(name="axon.axonserver.enabled", matchIfMissing=true) public class AxonServerBusAutoConfiguration extends Object
Constructor and Description |
---|
AxonServerBusAutoConfiguration() |
Modifier and Type | Method and Description |
---|---|
AxonServerCommandBus |
axonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration axonServerConfiguration,
CommandBus localSegment,
Serializer messageSerializer,
RoutingStrategy routingStrategy,
CommandPriorityCalculator priorityCalculator,
CommandLoadFactorProvider loadFactorProvider,
TargetContextResolver<? super CommandMessage<?>> targetContextResolver,
SpanFactory spanFactory) |
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) |
@Bean @Primary @ConditionalOnMissingQualifiedBean(qualifier="!localSegment", beanClass=CommandBus.class) public AxonServerCommandBus axonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager, AxonServerConfiguration axonServerConfiguration, @Qualifier(value="localSegment") CommandBus localSegment, @Qualifier(value="messageSerializer") Serializer messageSerializer, RoutingStrategy routingStrategy, CommandPriorityCalculator priorityCalculator, CommandLoadFactorProvider loadFactorProvider, TargetContextResolver<? super CommandMessage<?>> targetContextResolver, SpanFactory spanFactory)
@Bean @ConditionalOnMissingBean(value=QueryBus.class) public AxonServerQueryBus queryBus(AxonServerConnectionManager axonServerConnectionManager, AxonServerConfiguration axonServerConfiguration, Configuration axonConfiguration, TransactionManager txManager, @Qualifier(value="messageSerializer") Serializer messageSerializer, Serializer genericSerializer, QueryPriorityCalculator priorityCalculator, QueryInvocationErrorHandler queryInvocationErrorHandler, TargetContextResolver<? super QueryMessage<?,?>> targetContextResolver)
@Bean @ConditionalOnMissingBean public EventStore eventStore(AxonServerConfiguration axonServerConfiguration, Configuration configuration, AxonServerConnectionManager axonServerConnectionManager, Serializer snapshotSerializer, @Qualifier(value="eventSerializer") Serializer eventSerializer)
Copyright © 2010–2023. All rights reserved.