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.queryhandling
org.axonframework.queryhandling.annotation

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 around GRPC QueryRequest to implement the QueryMessage interface

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

Modifier and Type	Method and Description
QueryMessage<Q,R>	GrpcBackedQueryMessage.andMetaData(Map<String,?> metaData)
<Q,R> QueryMessage<Q,R>	QuerySerializer.deserializeRequest(QueryRequest query)
QueryMessage<Q,R>	GrpcBackedQueryMessage.withMetaData(Map<String,?> metaData)

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

Modifier and Type	Method and Description
default int	QueryPriorityCalculator.determinePriority(QueryMessage<?,?> queryMessage)
<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> QueryRequest	QuerySerializer.serializeRequest(QueryMessage<Q,R> queryMessage, int nrResults, long timeout, int priority)

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)

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 name) Registers new metrics to the registry to monitor a CommandBus.

Uses of QueryMessage in org.axonframework.queryhandling

Subinterfaces of QueryMessage in org.axonframework.queryhandling

Modifier and Type	Interface and Description
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	GenericSubscriptionQueryMessage<Q,I,U> Generic implementation of the SubscriptionQueryMessage.

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 with parameters of type QueryMessage

Modifier and Type	Method and Description
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.

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)