Package | Description |
---|---|
org.axonframework.axonserver.connector.command |
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. |
static AxonServerCommandBus.Builder |
AxonServerCommandBus.builder()
Instantiate a Builder to be able to create an
AxonServerCommandBus . |
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. |
AxonServerCommandBus.Builder |
AxonServerCommandBus.Builder.defaultCommandCallback(CommandCallback<Object,Object> defaultCommandCallback)
Sets the callback to use when commands are dispatched in a "fire and forget" method, such as
AxonServerCommandBus.dispatch(CommandMessage) . |
AxonServerCommandBus.Builder |
AxonServerCommandBus.Builder.executorServiceBuilder(ExecutorServiceBuilder executorServiceBuilder)
Sets the
ExecutorServiceBuilder which builds an ExecutorService based on a given
AxonServerConfiguration and BlockingQueue of Runnable . |
AxonServerCommandBus.Builder |
AxonServerCommandBus.Builder.instructionAckSource(InstructionAckSource<CommandProviderOutbound> instructionAckSource)
Sets the instruction ack source used to send instruction acknowledgements.
|
AxonServerCommandBus.Builder |
AxonServerCommandBus.Builder.loadFactorProvider(CommandLoadFactorProvider loadFactorProvider)
Sets the
CommandLoadFactorProvider which provides the load factor values for all commands this
client can handle. |
AxonServerCommandBus.Builder |
AxonServerCommandBus.Builder.localSegment(CommandBus localSegment)
Sets the local
CommandBus used to dispatch incoming commands to the local environment. |
AxonServerCommandBus.Builder |
AxonServerCommandBus.Builder.priorityCalculator(CommandPriorityCalculator priorityCalculator)
Sets the
CommandPriorityCalculator used to deduce the priority of an incoming command among other
commands, to give precedence over high(er) valued queries for example. |
AxonServerCommandBus.Builder |
AxonServerCommandBus.Builder.requestStreamFactory(Function<UpstreamAwareStreamObserver<CommandProviderInbound>,io.grpc.stub.StreamObserver<CommandProviderOutbound>> requestStreamFactory)
Sets the request stream factory that creates a request stream based on upstream.
|
AxonServerCommandBus.Builder |
AxonServerCommandBus.Builder.routingStrategy(RoutingStrategy routingStrategy)
Sets the
RoutingStrategy used to correctly configure connections between Axon clients and
Axon Server. |
AxonServerCommandBus.Builder |
AxonServerCommandBus.Builder.serializer(Serializer serializer)
Sets the
Serializer used to de-/serialize incoming and outgoing commands and command results. |
AxonServerCommandBus.Builder |
AxonServerCommandBus.Builder.targetContextResolver(TargetContextResolver<? super CommandMessage<?>> targetContextResolver)
Sets the
TargetContextResolver used to resolve the target (bounded) context of an ingested
CommandMessage . |
Constructor and Description |
---|
AxonServerCommandBus(AxonServerCommandBus.Builder builder)
Instantiate a
AxonServerCommandBus based on the fields contained in the AxonServerCommandBus.Builder . |
Copyright © 2010–2020. All rights reserved.