Uses of Class
org.axonframework.axonserver.connector.query.AxonServerQueryBus.Builder
Packages that use AxonServerQueryBus.Builder
-
Uses of AxonServerQueryBus.Builder in org.axonframework.axonserver.connector.query
Methods in org.axonframework.axonserver.connector.query that return AxonServerQueryBus.BuilderModifier and TypeMethodDescriptionAxonServerQueryBus.Builder.axonServerConnectionManager(AxonServerConnectionManager axonServerConnectionManager) Sets theAxonServerConnectionManagerused to create connections between this application and an Axon Server instance.static AxonServerQueryBus.BuilderAxonServerQueryBus.builder()Instantiate a Builder to be able to create anAxonServerQueryBus.AxonServerQueryBus.Builder.configuration(AxonServerConfiguration configuration) Sets theAxonServerConfigurationused 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.defaultContext(String defaultContext) Sets the default context for this event store to connect to.AxonServerQueryBus.Builder.enabledLocalSegmentShortCut()Enables shortcut to localQueryBus.AxonServerQueryBus.Builder.executorServiceBuilder(ExecutorServiceBuilder executorServiceBuilder) Deprecated.AxonServerQueryBus.Builder.genericSerializer(Serializer genericSerializer) Sets the genericSerializerused to de-/serialize incoming and outgoing queryResponseTypeimplementations.AxonServerQueryBus.Builder.instructionAckSource(InstructionAckSource<io.axoniq.axonserver.grpc.query.QueryProviderOutbound> instructionAckSource) Deprecated.in through use of the AxonServer java connectorAxonServerQueryBus.Builder.localSegment(QueryBus localSegment) Sets the localQueryBusused to dispatch incoming queries to the local environment.AxonServerQueryBus.Builder.messageSerializer(Serializer messageSerializer) Sets the messageSerializerused to de-/serialize incoming and outgoing queries and query responses.AxonServerQueryBus.Builder.priorityCalculator(QueryPriorityCalculator priorityCalculator) Sets theQueryPriorityCalculatorused to deduce the priority of an incoming query among other queries, to give precedence over high(er) valued queries for example.AxonServerQueryBus.Builder.queryExecutorServiceBuilder(ExecutorServiceBuilder executorServiceBuilder) Sets theExecutorServiceBuilderwhich builds anExecutorServicebased on a givenAxonServerConfigurationandBlockingQueueofRunnable.AxonServerQueryBus.Builder.queryInProgressAwait(Duration queryInProgressAwait) Sets thequery in progress await timeoutused to await the successful termination of queries in progress.AxonServerQueryBus.Builder.queryResponseExecutorServiceBuilder(ExecutorServiceBuilder executorServiceBuilder) Sets theExecutorServiceBuilderwhich builds anExecutorServicebased on a givenAxonServerConfigurationandBlockingQueueofRunnable.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 connectorAxonServerQueryBus.Builder.spanFactory(QueryBusSpanFactory spanFactory) Sets theQueryBusSpanFactoryimplementation to use for providing tracing capabilities.AxonServerQueryBus.Builder.spanFactory(SpanFactory spanFactory) Deprecated.UsespanFactory(QueryBusSpanFactory)instead as it provides more configurability.AxonServerQueryBus.Builder.targetContextResolver(TargetContextResolver<? super QueryMessage<?, ?>> targetContextResolver) Sets theTargetContextResolverused to resolve the target (bounded) context of an ingestedQueryMessage.AxonServerQueryBus.Builder.updateEmitter(QueryUpdateEmitter updateEmitter) Sets theQueryUpdateEmitterwhich can be used to emit updates to queries.Constructors in org.axonframework.axonserver.connector.query with parameters of type AxonServerQueryBus.BuilderModifierConstructorDescriptionInstantiate aAxonServerQueryBusbased on the fields contained in theAxonServerQueryBus.Builder.
queryExecutorServiceBuilder(ExecutorServiceBuilder)method