Uses of Interface
org.axonframework.queryhandling.QueryMessage

Packages that use QueryMessage

Package	Description
org.axonframework.axonserver.connector.query
org.axonframework.axonserver.connector.query.subscription
org.axonframework.metrics
org.axonframework.micrometer
org.axonframework.queryhandling
org.axonframework.queryhandling.annotation
org.axonframework.springboot.autoconfig

Uses of QueryMessage in org.axonframework.axonserver.connector.query

Classes in org.axonframework.axonserver.connector.query that implement QueryMessage

Modifier and Type	Class and Description
class	GrpcBackedQueryMessage<Q,R> Wrapper that allows clients to access a gRPC QueryRequest as a QueryMessage.

Methods in org.axonframework.axonserver.connector.query that return QueryMessage

Modifier and Type	Method and Description
<Q,R> QueryMessage<Q,R>	QuerySerializer.deserializeRequest(io.axoniq.axonserver.grpc.query.QueryRequest queryRequest) Convert a QueryRequest into a QueryMessage.

Methods in org.axonframework.axonserver.connector.query with parameters of type QueryMessage

Modifier and Type	Method and Description
int	QueryPriorityCalculator.determinePriority(QueryMessage<?,?> query) Determines the priority of the given query.
<Q,R> CompletableFuture<QueryResponseMessage<R>>	AxonServerQueryBus.query(QueryMessage<Q,R> queryMessage)
<Q,R> Stream<QueryResponseMessage<R>>	AxonServerQueryBus.scatterGather(QueryMessage<Q,R> queryMessage, long timeout, TimeUnit timeUnit)
<Q,R> io.axoniq.axonserver.grpc.query.QueryRequest	QuerySerializer.serializeRequest(QueryMessage<Q,R> queryMessage, int nrResults, long timeout, int priority) Convert a QueryMessage into a QueryRequest.
<Q,R> io.axoniq.axonserver.grpc.query.QueryRequest	QuerySerializer.serializeRequest(QueryMessage<Q,R> queryMessage, int nrResults, long timeout, int priority, boolean stream) Convert a QueryMessage into a QueryRequest.

Method parameters in org.axonframework.axonserver.connector.query with type arguments of type QueryMessage

Modifier and Type	Method and Description
Registration	AxonServerQueryBus.registerDispatchInterceptor(MessageDispatchInterceptor<? super QueryMessage<?,?>> dispatchInterceptor)
Registration	AxonServerQueryBus.registerHandlerInterceptor(MessageHandlerInterceptor<? super QueryMessage<?,?>> interceptor)
<R> Registration	AxonServerQueryBus.subscribe(String queryName, Type responseType, MessageHandler<? super QueryMessage<?,R>> handler)
AxonServerQueryBus.Builder	AxonServerQueryBus.Builder.targetContextResolver(TargetContextResolver<? super QueryMessage<?,?>> targetContextResolver) Sets the TargetContextResolver used to resolve the target (bounded) context of an ingested QueryMessage.

Uses of QueryMessage in org.axonframework.axonserver.connector.query.subscription

Classes in org.axonframework.axonserver.connector.query.subscription that implement QueryMessage

Modifier and Type	Class and Description
class	GrpcBackedSubscriptionQueryMessage<Q,I,U> Wrapper that allows clients to access a gRPC SubscriptionQuery message as a SubscriptionQueryMessage.

Uses of QueryMessage in org.axonframework.metrics

Methods in org.axonframework.metrics that return types with arguments of type QueryMessage

Modifier and Type	Method and Description
MessageMonitor<? super QueryMessage<?,?>>	GlobalMetricRegistry.registerQueryBus(String queryBusName) Registers new metrics to the registry to monitor a QueryBus.

Uses of QueryMessage in org.axonframework.micrometer

Methods in org.axonframework.micrometer that return types with arguments of type QueryMessage

Modifier and Type	Method and Description
MessageMonitor<? super QueryMessage<?,?>>	GlobalMetricRegistry.registerQueryBus(String queryBusName) Registers new metrics to the registry to monitor a QueryBus.
MessageMonitor<? super QueryMessage<?,?>>	GlobalMetricRegistry.registerQueryBus(String queryBusName, Function<Message<?>,Iterable<io.micrometer.core.instrument.Tag>> tagsBuilder) Registers new metrics to the registry to monitor a QueryBus using Tags through the given tagsBuilder.

Uses of QueryMessage in org.axonframework.queryhandling

Subinterfaces of QueryMessage in org.axonframework.queryhandling

Modifier and Type	Interface and Description
interface	StreamingQueryMessage<Q,R> A special type of QueryMessage used for initiating streaming queries.
interface	SubscriptionQueryMessage<Q,I,U> Message type that carries a Subscription Query: a request for information.

Classes in org.axonframework.queryhandling that implement QueryMessage

Modifier and Type	Class and Description
class	GenericQueryMessage<T,R> Generic implementation of the QueryMessage.
class	GenericStreamingQueryMessage<Q,R> Generic implementation of the StreamingQueryMessage.
class	GenericSubscriptionQueryMessage<Q,I,U> Generic implementation of the SubscriptionQueryMessage.

Methods in org.axonframework.queryhandling with type parameters of type QueryMessage

Modifier and Type	Method and Description
<T,R,M extends QueryMessage<T,R>> M	QueryBusSpanFactory.propagateContext(M queryMessage) Propagates the context of the current span to the given queryMessage.
<T,R,M extends QueryMessage<T,R>> M	DefaultQueryBusSpanFactory.propagateContext(M queryMessage)

Methods in org.axonframework.queryhandling that return QueryMessage

Modifier and Type	Method and Description
QueryMessage<T,R>	QueryMessage.andMetaData(Map<String,?> additionalMetaData) Returns a copy of this QueryMessage with its MetaData merged with given metaData.
QueryMessage<T,R>	GenericQueryMessage.andMetaData(Map<String,?> metaData)
QueryMessage<T,R>	QueryMessage.withMetaData(Map<String,?> metaData) Returns a copy of this QueryMessage with the given metaData.
QueryMessage<T,R>	GenericQueryMessage.withMetaData(Map<String,?> metaData)

Methods in org.axonframework.queryhandling that return types with arguments of type QueryMessage

Modifier and Type	Method and Description
MessageHandler<? super QueryMessage<?,R>>	QuerySubscription.getQueryHandler() Retrieve the query handler of this subscription as a MessageHandler.

Methods in org.axonframework.queryhandling with parameters of type QueryMessage

Modifier and Type	Method and Description
Span	QueryBusSpanFactory.createQueryProcessingSpan(QueryMessage<?,?> queryMessage) Creates a span for processing a query.
Span	DefaultQueryBusSpanFactory.createQueryProcessingSpan(QueryMessage<?,?> queryMessage)
Span	QueryBusSpanFactory.createQuerySpan(QueryMessage<?,?> queryMessage, boolean distributed) Creates a span for a query.
Span	DefaultQueryBusSpanFactory.createQuerySpan(QueryMessage<?,?> queryMessage, boolean distributed)
Span	QueryBusSpanFactory.createResponseProcessingSpan(QueryMessage<?,?> queryMessage) Creates a span for processing a response.
Span	DefaultQueryBusSpanFactory.createResponseProcessingSpan(QueryMessage<?,?> queryMessage)
Span	QueryBusSpanFactory.createScatterGatherHandlerSpan(QueryMessage<?,?> queryMessage, int handlerIndex) Creates a span for one of the handlers of a scatter-gather query.
Span	DefaultQueryBusSpanFactory.createScatterGatherHandlerSpan(QueryMessage<?,?> queryMessage, int handlerIndex)
Span	QueryBusSpanFactory.createScatterGatherSpan(QueryMessage<?,?> queryMessage, boolean distributed) Creates a span for a scatter-gather query.
Span	DefaultQueryBusSpanFactory.createScatterGatherSpan(QueryMessage<?,?> queryMessage, boolean distributed)
Span	QueryBusSpanFactory.createStreamingQuerySpan(QueryMessage<?,?> queryMessage, boolean distributed) Creates a span for a streaming query.
Span	DefaultQueryBusSpanFactory.createStreamingQuerySpan(QueryMessage<?,?> queryMessage, boolean distributed)
void	QueryInvocationErrorHandler.onError(Throwable error, QueryMessage<?,?> queryMessage, MessageHandler messageHandler) Invoked when an error occurred while invoking a message handler in a scatter-gather query.
void	LoggingQueryInvocationErrorHandler.onError(Throwable error, QueryMessage<?,?> queryMessage, MessageHandler messageHandler)
<Q,R> CompletableFuture<QueryResponseMessage<R>>	SimpleQueryBus.query(QueryMessage<Q,R> query)
<Q,R> CompletableFuture<QueryResponseMessage<R>>	QueryBus.query(QueryMessage<Q,R> query) Dispatch the given query to a single QueryHandler subscribed to the given query's queryName and responseType.
<Q,R> Stream<QueryResponseMessage<R>>	SimpleQueryBus.scatterGather(QueryMessage<Q,R> query, long timeout, TimeUnit unit)
<Q,R> Stream<QueryResponseMessage<R>>	QueryBus.scatterGather(QueryMessage<Q,R> query, long timeout, TimeUnit unit) Dispatch the given query to all QueryHandlers subscribed to the given query's queryName/responseType.

Method parameters in org.axonframework.queryhandling with type arguments of type QueryMessage

Modifier and Type	Method and Description
DefaultQueryGateway.Builder	DefaultQueryGateway.Builder.dispatchInterceptors(List<MessageDispatchInterceptor<? super QueryMessage<?,?>>> dispatchInterceptors) Sets the List of MessageDispatchInterceptors for QueryMessages.
SimpleQueryBus.Builder	SimpleQueryBus.Builder.messageMonitor(MessageMonitor<? super QueryMessage<?,?>> messageMonitor) Sets the MessageMonitor used to monitor query messages.
Registration	SimpleQueryBus.registerDispatchInterceptor(MessageDispatchInterceptor<? super QueryMessage<?,?>> interceptor) Registers an interceptor that intercepts Queries as they are sent.
Registration	DefaultQueryGateway.registerDispatchInterceptor(MessageDispatchInterceptor<? super QueryMessage<?,?>> interceptor)
Registration	SimpleQueryBus.registerHandlerInterceptor(MessageHandlerInterceptor<? super QueryMessage<?,?>> interceptor) Registers an interceptor that is used to intercept Queries before they are passed to their respective handlers.
<R> Registration	SimpleQueryBus.subscribe(String queryName, Type responseType, MessageHandler<? super QueryMessage<?,R>> handler)
<R> Registration	QueryBus.subscribe(String queryName, Type responseType, MessageHandler<? super QueryMessage<?,R>> handler) Subscribe the given handler to queries with the given queryName and responseType.

Constructors in org.axonframework.queryhandling with parameters of type QueryMessage

Constructor and Description
NoHandlerForQueryException(QueryMessage<?,?> query) Initialize this exception with a message describing the given QueryMessage.

Constructor parameters in org.axonframework.queryhandling with type arguments of type QueryMessage

Constructor and Description
QuerySubscription(Type responseType, MessageHandler<? super QueryMessage<?,R>> queryHandler) Instantiate a QuerySubscription with a specific responseType and queryHandler.

Uses of QueryMessage in org.axonframework.queryhandling.annotation

Methods in org.axonframework.queryhandling.annotation with parameters of type QueryMessage

Modifier and Type	Method and Description
boolean	AnnotationQueryHandlerAdapter.canHandle(QueryMessage<?,?> message)
Object	AnnotationQueryHandlerAdapter.handle(QueryMessage<?,?> message)

Uses of QueryMessage in org.axonframework.springboot.autoconfig

Method parameters in org.axonframework.springboot.autoconfig with type arguments of type QueryMessage

Modifier and Type

Method and Description

AxonServerQueryBus

AxonServerBusAutoConfiguration.queryBus(AxonServerConnectionManager axonServerConnectionManager, AxonServerConfiguration axonServerConfiguration, Configuration axonConfiguration, TransactionManager txManager, Serializer messageSerializer, Serializer genericSerializer, QueryPriorityCalculator priorityCalculator, QueryInvocationErrorHandler queryInvocationErrorHandler, TargetContextResolver<? super QueryMessage<?,?>> targetContextResolver)