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.

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	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	DefaultQueryGateway.registerDispatchInterceptor(MessageDispatchInterceptor<? super QueryMessage<?,?>> interceptor)
Registration	SimpleQueryBus.registerDispatchInterceptor(MessageDispatchInterceptor<? super QueryMessage<?,?>> interceptor) Registers an interceptor that intercepts Queries as they are sent.
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)

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

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