Modifier and Type | Method and Description |
---|---|
AxonServerConfiguration |
AxonServerConfiguration.Builder.build()
Initializes a
AxonServerConfiguration as specified through this Builder. |
Modifier and Type | Method and Description |
---|---|
AxonServerConnectionManager.Builder |
AxonServerConnectionManager.Builder.axonServerConfiguration(AxonServerConfiguration axonServerConfiguration)
Sets the
AxonServerConfiguration used to correctly configure connections between Axon clients and
Axon Server. |
Modifier and Type | Method and Description |
---|---|
AxonServerCommandBus.Builder |
AxonServerCommandBus.Builder.configuration(AxonServerConfiguration configuration)
Sets the
AxonServerConfiguration used to configure several components within the Axon Server Command
Bus, like setting the client id or the number of command handling threads used. |
Constructor and Description |
---|
CommandSerializer(Serializer serializer,
AxonServerConfiguration configuration)
Instantiate a serializer used to convert Axon
CommandMessage s and CommandResultMessage s into Axon
Server gRPC messages and vice versa. |
Modifier and Type | Method and Description |
---|---|
AxonServerEventStore.Builder |
AxonServerEventStore.Builder.configuration(AxonServerConfiguration configuration)
Sets the
AxonServerConfiguration describing the servers to connect with and how to manage flow
control. |
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 |
---|
EventProcessorControlService(AxonServerConnectionManager axonServerConnectionManager,
EventProcessingConfiguration eventProcessingConfiguration,
AxonServerConfiguration axonServerConfiguration)
Initialize a
EventProcessorControlService which adds Consumer s to the given
AxonServerConnectionManager on PlatformOutboundInstruction s. |
Modifier and Type | Method and Description |
---|---|
AxonServerQueryBus.Builder |
AxonServerQueryBus.Builder.configuration(AxonServerConfiguration configuration)
Sets the
AxonServerConfiguration used to configure several components within the Axon Server Query
Bus, like setting the client id or the number of query handling threads used. |
Constructor and Description |
---|
QuerySerializer(Serializer messageSerializer,
Serializer serializer,
AxonServerConfiguration configuration)
Instantiate a serializer used to convert Axon
QueryMessage s and QueryResponseMessage s into Axon
Server gRPC messages and vice versa. |
Constructor and Description |
---|
SubscriptionMessageSerializer(Serializer messageSerializer,
Serializer serializer,
AxonServerConfiguration configuration)
Instantiate a serializer used to convert Axon
SubscriptionQueryMessage s, the initial QueryResponseMessage and the subsequent SubscriptionQueryUpdateMessage s into Axon Server gRPC messages
and vice versa. |
Constructor and Description |
---|
FlowControllingStreamObserver(io.grpc.stub.StreamObserver<T> wrappedStreamObserver,
AxonServerConfiguration configuration,
Function<io.axoniq.axonserver.grpc.FlowControl,T> requestWrapper,
Predicate<T> isConfirmationMessage)
Deprecated.
Constructs a
FlowControllingStreamObserver . |
Modifier and Type | Method and Description |
---|---|
AxonServerConfiguration |
AxonServerAutoConfiguration.axonServerConfiguration() |
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) |
CommandLoadFactorProvider |
AxonServerAutoConfiguration.commandLoadFactorProvider(AxonServerConfiguration configuration) |
EventStore |
AxonServerAutoConfiguration.eventStore(AxonServerConfiguration axonServerConfiguration,
AxonConfiguration configuration,
AxonServerConnectionManager axonServerConnectionManager,
Serializer snapshotSerializer,
Serializer eventSerializer) |
AxonServerConnectionManager |
AxonServerAutoConfiguration.platformConnectionManager(AxonServerConfiguration axonServerConfiguration,
TagsConfigurationProperties tagsConfigurationProperties) |
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.