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	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	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	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	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	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	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	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	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	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	Description
<T, R, M extends QueryMessage<T, R>> M	DefaultQueryBusSpanFactory.propagateContext(M queryMessage)
<T, R, M extends QueryMessage<T, R>> M	QueryBusSpanFactory.propagateContext(M queryMessage)	Propagates the context of the current span to the given queryMessage.

Methods in org.axonframework.queryhandling that return QueryMessage

Modifier and Type	Method	Description
QueryMessage<T,R>	GenericQueryMessage.andMetaData(Map<String,?> metaData)
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.withMetaData(Map<String,?> metaData)
QueryMessage<T,R>	QueryMessage.withMetaData(Map<String,?> metaData)	Returns a copy of this QueryMessage with the given metaData.

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

Modifier and Type	Method	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	Description
Span	DefaultQueryBusSpanFactory.createQueryProcessingSpan(QueryMessage<?,?> queryMessage)
Span	QueryBusSpanFactory.createQueryProcessingSpan(QueryMessage<?,?> queryMessage)	Creates a span for processing a query.
Span	DefaultQueryBusSpanFactory.createQuerySpan(QueryMessage<?,?> queryMessage, boolean distributed)
Span	QueryBusSpanFactory.createQuerySpan(QueryMessage<?,?> queryMessage, boolean distributed)	Creates a span for a query.
Span	DefaultQueryBusSpanFactory.createResponseProcessingSpan(QueryMessage<?,?> queryMessage)
Span	QueryBusSpanFactory.createResponseProcessingSpan(QueryMessage<?,?> queryMessage)	Creates a span for processing a response.
Span	DefaultQueryBusSpanFactory.createScatterGatherHandlerSpan(QueryMessage<?,?> queryMessage, int handlerIndex)
Span	QueryBusSpanFactory.createScatterGatherHandlerSpan(QueryMessage<?,?> queryMessage, int handlerIndex)	Creates a span for one of the handlers of a scatter-gather query.
Span	DefaultQueryBusSpanFactory.createScatterGatherSpan(QueryMessage<?,?> queryMessage, boolean distributed)
Span	QueryBusSpanFactory.createScatterGatherSpan(QueryMessage<?,?> queryMessage, boolean distributed)	Creates a span for a scatter-gather query.
Span	DefaultQueryBusSpanFactory.createStreamingQuerySpan(QueryMessage<?,?> queryMessage, boolean distributed)
Span	QueryBusSpanFactory.createStreamingQuerySpan(QueryMessage<?,?> queryMessage, boolean distributed)	Creates a span for a streaming query.
void	LoggingQueryInvocationErrorHandler.onError(Throwable error, QueryMessage<?,?> queryMessage, MessageHandler messageHandler)
void	QueryInvocationErrorHandler.onError(Throwable error, QueryMessage<?,?> queryMessage, MessageHandler messageHandler)	Invoked when an error occurred while invoking a message handler in a scatter-gather 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> CompletableFuture<QueryResponseMessage<R>>	SimpleQueryBus.query(QueryMessage<Q,R> query)
<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.
<Q, R> Stream<QueryResponseMessage<R>>	SimpleQueryBus.scatterGather(QueryMessage<Q,R> query, long timeout, TimeUnit unit)

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

Modifier and Type	Method	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	QueryBus.subscribe(String queryName, Type responseType, MessageHandler<? super QueryMessage<?,R>> handler)	Subscribe the given handler to queries with the given queryName and responseType.
<R> Registration	SimpleQueryBus.subscribe(String queryName, Type responseType, MessageHandler<? super QueryMessage<?,R>> handler)

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

Modifier	Constructor	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

Modifier	Constructor	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	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	Description
AxonServerQueryBus	AxonServerBusAutoConfiguration.queryBus(AxonServerConnectionManager axonServerConnectionManager, AxonServerConfiguration axonServerConfiguration, Configuration axonConfiguration, TransactionManager txManager, Serializer messageSerializer, Serializer genericSerializer, QueryPriorityCalculator priorityCalculator, QueryInvocationErrorHandler queryInvocationErrorHandler, TargetContextResolver<? super QueryMessage<?,?>> targetContextResolver)
org.springframework.beans.factory.InitializingBean	InterceptorAutoConfiguration.queryDispatchInterceptorConfigurer(QueryGateway queryGateway, Optional<List<MessageDispatchInterceptor<? super QueryMessage<?,?>>>> interceptors)
org.springframework.beans.factory.InitializingBean	InterceptorAutoConfiguration.queryHandlerInterceptorConfigurer(QueryBus queryBus, Optional<List<MessageHandlerInterceptor<? super QueryMessage<?,?>>>> interceptors)