@AutoConfiguration @AutoConfigureBefore(value=AxonAutoConfiguration.class) @ConditionalOnClass(value=AxonServerConfiguration.class) @EnableConfigurationProperties(value=TagsConfigurationProperties.class) @ConditionalOnProperty(name="axon.axonserver.enabled", matchIfMissing=true) public class AxonServerAutoConfiguration extends Object
Modifier and Type | Class and Description |
---|---|
static class |
AxonServerAutoConfiguration.ConnectionConfiguration |
static class |
AxonServerAutoConfiguration.ConnectionDetailsConfiguration |
Constructor and Description |
---|
AxonServerAutoConfiguration() |
@Bean @ConditionalOnMissingBean public ManagedChannelCustomizer managedChannelCustomizer()
@Bean public AxonServerConnectionManager platformConnectionManager(AxonServerConfiguration axonServerConfiguration, TagsConfigurationProperties tagsConfigurationProperties, ManagedChannelCustomizer managedChannelCustomizer)
@Bean @ConditionalOnMissingBean public RoutingStrategy routingStrategy()
@Bean @ConditionalOnMissingBean public CommandPriorityCalculator commandPriorityCalculator()
@Bean @ConditionalOnMissingBean public CommandLoadFactorProvider commandLoadFactorProvider(AxonServerConfiguration configuration)
@Bean @ConditionalOnMissingBean public QueryPriorityCalculator queryPriorityCalculator()
@Bean @ConditionalOnMissingBean public QueryInvocationErrorHandler queryInvocationErrorHandler()
@ConditionalOnMissingBean @Bean public TargetContextResolver<Message<?>> targetContextResolver()
@Bean @ConditionalOnMissingClass(value="org.axonframework.extensions.multitenancy.autoconfig.MultiTenancyAxonServerAutoConfiguration") public EventProcessorInfoConfiguration processorInfoConfiguration(EventProcessingConfiguration eventProcessingConfiguration, AxonServerConnectionManager connectionManager, AxonServerConfiguration configuration)
@Bean @ConditionalOnMissingBean @ConditionalOnProperty(name="axon.axonserver.event-store.enabled", matchIfMissing=true) public EventScheduler eventScheduler(@Qualifier(value="eventSerializer") Serializer eventSerializer, AxonServerConnectionManager connectionManager)
@Bean @ConditionalOnMissingQualifiedBean(qualifier="persistentStreamScheduler") @ConditionalOnProperty(name="axon.axonserver.event-store.enabled", matchIfMissing=true) public ScheduledExecutorService persistentStreamScheduler()
ScheduledExecutorService
for persistent stream operations.ScheduledExecutorService
for persistent stream operations.@Bean @ConditionalOnProperty(name="axon.axonserver.event-store.enabled", matchIfMissing=true) public PersistentStreamMessageSourceRegistrar persistentStreamRegistrar(@Qualifier(value="persistentStreamScheduler") ScheduledExecutorService scheduledExecutorService, org.springframework.core.env.Environment environment)
PersistentStreamMessageSourceRegistrar
to create and register Spring beans for persistent
streams.scheduledExecutorService
- The ScheduledExecutorService
used for persistent stream operations.environment
- The Spring Environment
.PersistentStreamMessageSourceRegistrar
to create and register Spring beans for persistent
streams.@Bean @ConditionalOnMissingBean public PersistentStreamMessageSourceFactory persistentStreamMessageSourceFactory()
PersistentStreamMessageSourceFactory
if one is not already defined. This factory
is used to create instances of the PersistentStreamMessageSource
with specified configurations.
The returned factory creates a new PersistentStreamMessageSource
with the following parameters:
name
: The name of the persistent stream.configuration
: The Axon framework configuration.persistentStreamProperties
: Properties of the persistent stream.scheduler
: The ScheduledExecutorService
for scheduling tasks.batchSize
: The number of events to fetch in a single batch.context
: The context in which the persistent stream operates.PersistentStreamMessageSourceFactory
that constructs PersistentStreamMessageSource
instances.@Bean @ConditionalOnProperty(name="axon.axonserver.event-store.enabled", matchIfMissing=true) public ConfigurerModule persistentStreamProcessorsConfigurerModule(EventProcessorProperties processorProperties, AxonServerConfiguration axonServerConfiguration)
ConfigurerModule
to configure
sequencing policies
for persistent streams
connected to subscribing event processors
with
a dead letter queue.processorProperties
- Contains the configured event processors.axonServerConfiguration
- Contains the persistent stream definitions.ConfigurerModule
to configure
sequencing policies
for persistent streams
connected to subscribing event processors
with
a dead letter queue.Copyright © 2010–2024. All rights reserved.