| 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. |
| Constructor and Description |
|---|
AxonServerConnectionManager(AxonServerConfiguration axonServerConfiguration)
Deprecated.
in favor of using the
AxonServerConnectionManager.Builder (with the convenience AxonServerConnectionManager.builder() method)to instantiate
an Axon Server Connection Manager |
AxonServerConnectionManager(AxonServerConfiguration axonServerConfiguration,
TagsConfiguration tagsConfiguration)
Deprecated.
in favor of using the
AxonServerConnectionManager.Builder (with the convenience AxonServerConnectionManager.builder() method)to instantiate
an Axon Server Connection Manager |
| 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 |
|---|
AxonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration configuration,
CommandBus localSegment,
Serializer serializer,
RoutingStrategy routingStrategy)
Deprecated.
in favor of using the
AxonServerCommandBus.Builder (with the convenience AxonServerCommandBus.builder() method) to instantiate
an Axon Server Command Bus |
AxonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration configuration,
CommandBus localSegment,
Serializer serializer,
RoutingStrategy routingStrategy,
CommandPriorityCalculator priorityCalculator)
Deprecated.
in favor of using the
AxonServerCommandBus.Builder (with the convenience AxonServerCommandBus.builder() method) to instantiate
an Axon Server Command Bus |
AxonServerCommandBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration configuration,
CommandBus localSegment,
Serializer serializer,
RoutingStrategy routingStrategy,
CommandPriorityCalculator priorityCalculator,
TargetContextResolver<? super CommandMessage<?>> targetContextResolver)
Deprecated.
in favor of using the
AxonServerCommandBus.Builder (with the convenience AxonServerCommandBus.builder() method) to instantiate
an Axon Server Command Bus |
CommandSerializer(Serializer serializer,
AxonServerConfiguration configuration)
Instantiate a serializer used to convert Axon
CommandMessages and CommandResultMessages into Axon
Server gRPC messages and vice versa. |
| Constructor and Description |
|---|
AxonServerEventStoreClient(AxonServerConfiguration eventStoreConfiguration,
AxonServerConnectionManager axonServerConnectionManager)
Initialize the Event Store Client using given
eventStoreConfiguration and given platformConnectionManager. |
| 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)
Creates a
HeartbeatConfiguration using the provided functions to retrieve the AxonServerConnectionManager and AxonServerConfiguration. |
| 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 |
|---|
AxonServerQueryBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration configuration,
QueryUpdateEmitter updateEmitter,
QueryBus localSegment,
Serializer messageSerializer,
Serializer genericSerializer,
QueryPriorityCalculator priorityCalculator)
Deprecated.
in favor of using the
AxonServerQueryBus.Builder (with the convenience AxonServerQueryBus.builder() method) to instantiate
an Axon Server Query Bus |
AxonServerQueryBus(AxonServerConnectionManager axonServerConnectionManager,
AxonServerConfiguration configuration,
QueryUpdateEmitter updateEmitter,
QueryBus localSegment,
Serializer messageSerializer,
Serializer genericSerializer,
QueryPriorityCalculator priorityCalculator,
TargetContextResolver<? super QueryMessage<?,?>> targetContextResolver)
Deprecated.
in favor of using the
AxonServerQueryBus.Builder (with the convenience AxonServerQueryBus.builder() method) to instantiate
an Axon Server Query Bus |
QuerySerializer(Serializer messageSerializer,
Serializer serializer,
AxonServerConfiguration configuration)
Instantiate a serializer used to convert Axon
QueryMessages and QueryResponseMessages into Axon
Server gRPC messages and vice versa. |
| Constructor and Description |
|---|
AxonServerSubscriptionQueryResult(SubscriptionQuery subscriptionQuery,
Function<io.grpc.stub.StreamObserver<SubscriptionQueryResponse>,io.grpc.stub.StreamObserver<SubscriptionQueryRequest>> openStreamFn,
AxonServerConfiguration configuration,
SubscriptionQueryBackpressure backPressure,
int bufferSize,
Runnable onDispose)
Instantiate a
AxonServerSubscriptionQueryResult which will emit its initial response and the updates of
the subscription query. |
SubscriptionMessageSerializer(Serializer messageSerializer,
Serializer serializer,
AxonServerConfiguration configuration)
Instantiate a serializer used to convert Axon
SubscriptionQueryMessages, the initial
QueryResponseMessage and the subsequent SubscriptionQueryUpdateMessages into Axon Server gRPC
messages and vice versa. |
| Constructor and Description |
|---|
FlowControllingStreamObserver(io.grpc.stub.StreamObserver<T> wrappedStreamObserver,
AxonServerConfiguration configuration,
Function<FlowControl,T> requestWrapper,
Predicate<T> isConfirmationMessage) |
| Modifier and Type | Method and Description |
|---|---|
AxonServerConfiguration |
AxonServerAutoConfiguration.axonServerConfiguration() |
Copyright © 2010–2020. All rights reserved.