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.defaultContext(String defaultContext)
Sets the default context for this event store to connect to.
|
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<io.axoniq.axonserver.grpc.query.QueryProviderOutbound> instructionAckSource)
Deprecated.
in through use of the AxonServer
java connector
|
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<io.axoniq.axonserver.grpc.query.QueryProviderInbound>,io.grpc.stub.StreamObserver<io.axoniq.axonserver.grpc.query.QueryProviderOutbound>> requestStreamFactory)
Deprecated.
in through use of the AxonServer
java connector
|
AxonServerQueryBus.Builder |
AxonServerQueryBus.Builder.spanFactory(SpanFactory spanFactory)
Sets the
SpanFactory implementation to use for providing tracing capabilities. |
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–2023. All rights reserved.