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 Consumer s to the given
AxonServerConnectionManager on PlatformOutboundInstruction s. |
EventProcessorControlService(AxonServerConnectionManager axonServerConnectionManager,
EventProcessingConfiguration eventProcessingConfiguration,
String context)
Initialize a
EventProcessorControlService which adds Consumer s to the given
AxonServerConnectionManager on PlatformOutboundInstruction s. |
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.