| Modifier and Type | Method and Description |
|---|---|
AxonServerConnectionManager |
AxonServerConnectionManager.Builder.build()
Initializes a
AxonServerConnectionManager as specified through this Builder. |
| Modifier and Type | Method and Description |
|---|---|
AxonServerCommandBus.Builder |
AxonServerCommandBus.Builder.axonServerConnectionManager(AxonServerConnectionManager axonServerConnectionManager)
Sets the
AxonServerConnectionManager used to create connections between this application and an Axon
Server instance. |
| Modifier and Type | Method and Description |
|---|---|
AxonServerEventScheduler.Builder |
AxonServerEventScheduler.Builder.connectionManager(AxonServerConnectionManager axonServerConnectionManager)
Sets the
AxonServerConnectionManager used to create connections between this application and an Axon
Server instance. |
AxonServerEventStore.Builder |
AxonServerEventStore.Builder.platformConnectionManager(AxonServerConnectionManager axonServerConnectionManager)
Sets the
AxonServerConnectionManager managing the connections to the AxonServer platform. |
| Constructor and Description |
|---|
EventProcessorInfoConfiguration(Function<Configuration,EventProcessingConfiguration> eventProcessingConfiguration,
Function<Configuration,AxonServerConnectionManager> connectionManager,
Function<Configuration,AxonServerConfiguration> axonServerConfiguration)
Creates an EventProcessorInfoConfiguration using the provided functions to retrieve the
EventProcessingConfiguration, AxonServerConnectionManager and AxonServerConfiguration. |
| Constructor and Description |
|---|
HeartbeatConfiguration(Function<Configuration,AxonServerConnectionManager> connectionManagerSupplier,
Function<Configuration,AxonServerConfiguration> axonServerConfigurationSupplier)
Deprecated.
Creates a
HeartbeatConfiguration using the provided functions to retrieve the AxonServerConnectionManager and AxonServerConfiguration. |
| Constructor and Description |
|---|
ActiveGrpcChannelChecker(AxonServerConnectionManager connectionManager,
String context)
Deprecated.
Constructs an
ActiveGrpcChannelChecker based on the connection manager. |
HeartbeatConnectionChecker(AxonServerConnectionManager connectionManager,
String context)
Deprecated.
Constructs an instance of
HeartbeatConnectionChecker using the specified parameters. |
| Constructor and Description |
|---|
GrpcHeartbeatSource(AxonServerConnectionManager connectionManager,
String context)
Deprecated.
Creates a
GrpcHeartbeatSource which uses an AxonServerConnectionManager to send heartbeats
messages to AxonServer. |
| Constructor and Description |
|---|
EventProcessorControlService(AxonServerConnectionManager axonServerConnectionManager,
EventProcessingConfiguration eventProcessingConfiguration,
AxonServerConfiguration axonServerConfiguration)
Initialize a
EventProcessorControlService which adds Consumers to the given
AxonServerConnectionManager on PlatformOutboundInstructions. |
EventProcessorControlService(AxonServerConnectionManager axonServerConnectionManager,
EventProcessingConfiguration eventProcessingConfiguration,
String context)
Initialize a
EventProcessorControlService which adds Consumers to the given
AxonServerConnectionManager on PlatformOutboundInstructions. |
| Modifier and Type | Method and Description |
|---|---|
AxonServerQueryBus.Builder |
AxonServerQueryBus.Builder.axonServerConnectionManager(AxonServerConnectionManager axonServerConnectionManager)
Sets the
AxonServerConnectionManager used to create connections between this application and an Axon
Server instance. |
| Modifier and Type | Method and Description |
|---|---|
AxonServerConnectionManager |
AxonServerAutoConfiguration.platformConnectionManager(AxonServerConfiguration axonServerConfiguration,
TagsConfigurationProperties tagsConfigurationProperties) |
| Modifier and Type | Method and Description |
|---|---|
AxonServerCommandBus |
AxonServerAutoConfiguration.axonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration axonServerConfiguration,
CommandBus localSegment,
Serializer messageSerializer,
RoutingStrategy routingStrategy,
CommandPriorityCalculator priorityCalculator,
CommandLoadFactorProvider loadFactorProvider,
TargetContextResolver<? super CommandMessage<?>> targetContextResolver) |
EventScheduler |
AxonServerAutoConfiguration.eventScheduler(Serializer eventSerializer,
AxonServerConnectionManager connectionManager) |
EventStore |
AxonServerAutoConfiguration.eventStore(AxonServerConfiguration axonServerConfiguration,
AxonConfiguration configuration,
AxonServerConnectionManager axonServerConnectionManager,
Serializer snapshotSerializer,
Serializer eventSerializer) |
EventProcessorInfoConfiguration |
AxonServerAutoConfiguration.processorInfoConfiguration(EventProcessingConfiguration eventProcessingConfiguration,
AxonServerConnectionManager connectionManager,
AxonServerConfiguration configuration) |
AxonServerQueryBus |
AxonServerAutoConfiguration.queryBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration axonServerConfiguration,
AxonConfiguration axonConfiguration,
TransactionManager txManager,
Serializer messageSerializer,
Serializer genericSerializer,
QueryPriorityCalculator priorityCalculator,
QueryInvocationErrorHandler queryInvocationErrorHandler,
TargetContextResolver<? super QueryMessage<?,?>> targetContextResolver) |
Copyright © 2010–2020. All rights reserved.