Package | Description |
---|---|
org.axonframework.axonserver.connector.query |
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. |
static AxonServerQueryBus.Builder |
AxonServerQueryBus.builder()
Instantiate a Builder to be able to create an
AxonServerQueryBus . |
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. |
AxonServerQueryBus.Builder |
AxonServerQueryBus.Builder.executorServiceBuilder(ExecutorServiceBuilder executorServiceBuilder)
Sets the
ExecutorServiceBuilder which builds an ExecutorService based on a given AxonServerConfiguration and BlockingQueue of Runnable . |
AxonServerQueryBus.Builder |
AxonServerQueryBus.Builder.genericSerializer(Serializer genericSerializer)
Sets the generic
Serializer used to de-/serialize incoming and outgoing query ResponseType implementations. |
AxonServerQueryBus.Builder |
AxonServerQueryBus.Builder.instructionAckSource(InstructionAckSource<QueryProviderOutbound> instructionAckSource)
Sets the instruction ack source used to send instruction acknowledgements.
|
AxonServerQueryBus.Builder |
AxonServerQueryBus.Builder.localSegment(QueryBus localSegment)
Sets the local
QueryBus used to dispatch incoming queries to the local environment. |
AxonServerQueryBus.Builder |
AxonServerQueryBus.Builder.messageSerializer(Serializer messageSerializer)
Sets the message
Serializer used to de-/serialize incoming and outgoing queries and query responses. |
AxonServerQueryBus.Builder |
AxonServerQueryBus.Builder.priorityCalculator(QueryPriorityCalculator priorityCalculator)
Sets the
QueryPriorityCalculator used to deduce the priority of an incoming query among other
queries, to give precedence over high(er) valued queries for example. |
AxonServerQueryBus.Builder |
AxonServerQueryBus.Builder.requestStreamFactory(Function<UpstreamAwareStreamObserver<QueryProviderInbound>,io.grpc.stub.StreamObserver<QueryProviderOutbound>> requestStreamFactory)
Sets the request stream factory that creates a request stream based on upstream.
|
AxonServerQueryBus.Builder |
AxonServerQueryBus.Builder.targetContextResolver(TargetContextResolver<? super QueryMessage<?,?>> targetContextResolver)
Sets the
TargetContextResolver used to resolve the target (bounded) context of an ingested QueryMessage . |
AxonServerQueryBus.Builder |
AxonServerQueryBus.Builder.updateEmitter(QueryUpdateEmitter updateEmitter)
Sets the
QueryUpdateEmitter which can be used to emit updates to queries. |
Constructor and Description |
---|
AxonServerQueryBus(AxonServerQueryBus.Builder builder)
Instantiate a
AxonServerQueryBus based on the fields contained in the AxonServerQueryBus.Builder . |
Copyright © 2010–2020. All rights reserved.