Uses of Interface
org.axonframework.messaging.queryhandling.QueryMessage

Packages that use QueryMessage

Package	Description
org.axonframework.axonserver.connector.query
org.axonframework.extension.metrics.dropwizard
org.axonframework.extension.metrics.micrometer
org.axonframework.messaging.core.configuration
org.axonframework.messaging.core.interception
org.axonframework.messaging.core.timeout
org.axonframework.messaging.monitoring.configuration
org.axonframework.messaging.monitoring.interception
org.axonframework.messaging.queryhandling
org.axonframework.messaging.queryhandling.annotation
org.axonframework.messaging.queryhandling.distributed
org.axonframework.messaging.queryhandling.interception
org.axonframework.messaging.queryhandling.tracing

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

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

Modifier and Type	Method	Description
static QueryMessage	QueryConverter.convertQueryRequest(io.axoniq.axonserver.grpc.query.QueryRequest queryRequest)	Converts a QueryRequest into a QueryMessage.
static QueryMessage	QueryConverter.convertSubscriptionQueryMessage(io.axoniq.axonserver.grpc.query.SubscriptionQuery query)	Converts a SubscriptionQuery into a QueryMessage.

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

Modifier and Type	Method	Description
static io.axoniq.axonserver.grpc.query.QueryRequest	QueryConverter.convertQueryMessage(QueryMessage query, String clientId, String componentName)	Converts a QueryMessage into a QueryRequest.
MessageStream<QueryResponseMessage>	AxonServerQueryBusConnector.query(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	AxonServerQueryBusConnector.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)

Uses of QueryMessage in org.axonframework.extension.metrics.dropwizard

Methods in org.axonframework.extension.metrics.dropwizard 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.extension.metrics.micrometer

Methods in org.axonframework.extension.metrics.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.messaging.core.configuration

Method parameters in org.axonframework.messaging.core.configuration with type arguments of type QueryMessage

Modifier and Type	Method	Description
MessagingConfigurer	MessagingConfigurer.registerQueryDispatchInterceptor(ComponentBuilder<MessageDispatchInterceptor<? super QueryMessage>> interceptorBuilder)	Registers the given QueryMessage-specific MessageDispatchInterceptor factory in this Configurer.
MessagingConfigurer	MessagingConfigurer.registerQueryHandlerInterceptor(ComponentBuilder<MessageHandlerInterceptor<? super QueryMessage>> interceptorBuilder)	Registers the given QueryMessage MessageHandlerInterceptor factory in this Configurer.
MessagingConfigurer	MessagingConfigurer.registerQueryMonitor(ComponentBuilder<MessageMonitor<? super QueryMessage>> messageMonitorBuilder)	Registers a query monitor using the specified messageMonitorBuilder.

Uses of QueryMessage in org.axonframework.messaging.core.interception

Methods in org.axonframework.messaging.core.interception that return types with arguments of type QueryMessage

Modifier and Type	Method	Description
List<MessageDispatchInterceptor<? super QueryMessage>>	DefaultDispatchInterceptorRegistry.queryInterceptors(Configuration config)
List<MessageHandlerInterceptor<? super QueryMessage>>	DefaultHandlerInterceptorRegistry.queryInterceptors(Configuration config)
List<MessageDispatchInterceptor<? super QueryMessage>>	DispatchInterceptorRegistry.queryInterceptors(Configuration config)	Returns the list of QueryMessage-specific MessageDispatchInterceptors registered in this registry.
List<MessageHandlerInterceptor<? super QueryMessage>>	HandlerInterceptorRegistry.queryInterceptors(Configuration config)	Returns the list of QueryMessage-specific MessageHandlerInterceptors registered in this registry.

Method parameters in org.axonframework.messaging.core.interception with type arguments of type QueryMessage

Modifier and Type	Method	Description
DispatchInterceptorRegistry	DefaultDispatchInterceptorRegistry.registerQueryInterceptor(ComponentBuilder<MessageDispatchInterceptor<? super QueryMessage>> interceptorBuilder)
HandlerInterceptorRegistry	DefaultHandlerInterceptorRegistry.registerQueryInterceptor(ComponentBuilder<MessageHandlerInterceptor<? super QueryMessage>> interceptorBuilder)
DispatchInterceptorRegistry	DispatchInterceptorRegistry.registerQueryInterceptor(ComponentBuilder<MessageDispatchInterceptor<? super QueryMessage>> interceptorBuilder)	Registers the given interceptorBuilder for a QueryMessage-specific MessageDispatchInterceptor.
HandlerInterceptorRegistry	HandlerInterceptorRegistry.registerQueryInterceptor(ComponentBuilder<MessageHandlerInterceptor<? super QueryMessage>> interceptorBuilder)	Registers the given interceptorBuilder for a QueryMessage MessageHandlerInterceptor for all query handling infrastructure components

Uses of QueryMessage in org.axonframework.messaging.core.timeout

Methods in org.axonframework.messaging.core.timeout that return types with arguments of type QueryMessage

Modifier and Type	Method	Description
MessageHandlerInterceptor<QueryMessage>	UnitOfWorkTimeoutInterceptorBuilder.buildQueryInterceptor()	Constructs a QueryMessage handler interceptor, to be registered on (e.g.) the QueryBus.

Uses of QueryMessage in org.axonframework.messaging.monitoring.configuration

Methods in org.axonframework.messaging.monitoring.configuration that return types with arguments of type QueryMessage

Modifier and Type	Method	Description
MessageMonitor<? super QueryMessage>	DefaultMessageMonitorRegistry.queryMonitor(Configuration config)
MessageMonitor<? super QueryMessage>	MessageMonitorRegistry.queryMonitor(Configuration config)	Retrieves a MessageMonitor for monitoring the processing of QueryMessage instances.

Method parameters in org.axonframework.messaging.monitoring.configuration with type arguments of type QueryMessage

Modifier and Type	Method	Description
MessageMonitorRegistry	DefaultMessageMonitorRegistry.registerQueryMonitor(ComponentBuilder<MessageMonitor<? super QueryMessage>> monitorBuilder)
MessageMonitorRegistry	MessageMonitorRegistry.registerQueryMonitor(ComponentBuilder<MessageMonitor<? super QueryMessage>> monitorBuilder)	Registers a MessageMonitor specifically for QueryMessage types using the provided ComponentBuilder.

Uses of QueryMessage in org.axonframework.messaging.monitoring.interception

Methods in org.axonframework.messaging.monitoring.interception with parameters of type QueryMessage

Modifier and Type	Method	Description
MessageStream<?>	MonitoringQueryHandlerInterceptor.interceptOnHandle(QueryMessage message, ProcessingContext context, MessageHandlerInterceptorChain<QueryMessage> interceptorChain)

Method parameters in org.axonframework.messaging.monitoring.interception with type arguments of type QueryMessage

Modifier and Type	Method	Description
MessageStream<?>	MonitoringQueryHandlerInterceptor.interceptOnHandle(QueryMessage message, ProcessingContext context, MessageHandlerInterceptorChain<QueryMessage> interceptorChain)

Constructor parameters in org.axonframework.messaging.monitoring.interception with type arguments of type QueryMessage

Modifier	Constructor	Description
	MonitoringQueryHandlerInterceptor(MessageMonitor<? super QueryMessage> messageMonitor)	Constructs a MonitoringQueryHandlerInterceptor using the given MessageMonitor.

Uses of QueryMessage in org.axonframework.messaging.queryhandling

Classes in org.axonframework.messaging.queryhandling that implement QueryMessage

Modifier and Type	Class	Description
class	GenericQueryMessage	Generic implementation of the QueryMessage interface.

Methods in org.axonframework.messaging.queryhandling that return QueryMessage

Modifier and Type	Method	Description
QueryMessage	GenericQueryMessage.andMetadata(Map<String,String> metadata)
QueryMessage	QueryMessage.andMetadata(Map<String,String> additionalMetadata)
QueryMessage	GenericQueryMessage.withConvertedPayload(Type type, Converter converter)
default QueryMessage	QueryMessage.withConvertedPayload(Class<?> type, Converter converter)
QueryMessage	QueryMessage.withConvertedPayload(Type type, Converter converter)
default QueryMessage	QueryMessage.withConvertedPayload(TypeReference<?> type, Converter converter)
QueryMessage	GenericQueryMessage.withMetadata(Map<String,String> metadata)
QueryMessage	QueryMessage.withMetadata(Map<String,String> metadata)

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

Modifier and Type	Method	Description
int	QueryPriorityCalculator.determinePriority(QueryMessage query)	Determines the priority of the given query.
static NoHandlerForQueryException	NoHandlerForQueryException.forBus(QueryMessage query)	Constructs a NoHandlerForQueryException with a message describing the given QueryMessage, specific for QueryBuses.
static NoHandlerForQueryException	NoHandlerForQueryException.forHandlingComponent(QueryMessage query)	Constructs a NoHandlerForQueryException with a message describing the given QueryMessage, specific for QueryHandlingComponents.
MessageStream<QueryResponseMessage>	QueryHandler.handle(QueryMessage query, ProcessingContext context)	Handles the given query within the given context.
MessageStream<QueryResponseMessage>	SimpleQueryHandlingComponent.handle(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	QueryBus.query(QueryMessage query, ProcessingContext context)	Dispatch the given query to a QueryHandler subscribed to the given query's query name, returning a MessageStream of responses to the given query.
MessageStream<QueryResponseMessage>	SimpleQueryBus.query(QueryMessage query, ProcessingContext context)
MessageStream<SubscriptionQueryUpdateMessage>	QueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize)	Subscribes the given query with the given updateBufferSize, and returns the MessageStream that provides the update of the subscription query.
MessageStream<SubscriptionQueryUpdateMessage>	SimpleQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize)
MessageStream<QueryResponseMessage>	QueryBus.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)	Dispatch the given query to a single QueryHandler subscribed to the given query's queryName/initialResponseType/updateResponseType.
MessageStream<QueryResponseMessage>	SimpleQueryBus.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)

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

Modifier and Type	Method	Description
CompletableFuture<Void>	QueryBus.completeSubscriptions(Predicate<QueryMessage> filter, ProcessingContext context)	Completes subscription queries matching the given filter.
CompletableFuture<Void>	SimpleQueryBus.completeSubscriptions(Predicate<QueryMessage> filter, ProcessingContext context)
CompletableFuture<Void>	QueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, ProcessingContext context)	Completes subscription queries matching the given filter exceptionally with the given cause.
CompletableFuture<Void>	SimpleQueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, ProcessingContext context)
CompletableFuture<Void>	QueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, ProcessingContext context)	Emits the outcome of the updateSupplier to subscription queries matching the given queryName and given filter.
CompletableFuture<Void>	SimpleQueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, ProcessingContext context)

Uses of QueryMessage in org.axonframework.messaging.queryhandling.annotation

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

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	AnnotatedQueryHandlingComponent.handle(QueryMessage query, ProcessingContext context)

Uses of QueryMessage in org.axonframework.messaging.queryhandling.distributed

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

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	DelegatingQueryBusConnector.query(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	DistributedQueryBus.query(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	PayloadConvertingQueryBusConnector.query(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	QueryBusConnector.Handler.query(QueryMessage query)	Handles the incoming query message.
MessageStream<QueryResponseMessage>	QueryBusConnector.query(QueryMessage query, ProcessingContext context)	Sends the given query to the remote QueryBus.
Registration	QueryBusConnector.Handler.registerUpdateHandler(QueryMessage subscriptionQueryMessage, QueryBusConnector.UpdateCallback updateCallback)	Registers an update handler for a given subscription query message and its associated update sender.
MessageStream<SubscriptionQueryUpdateMessage>	DistributedQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize)
MessageStream<QueryResponseMessage>	DelegatingQueryBusConnector.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)
MessageStream<QueryResponseMessage>	DistributedQueryBus.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)
MessageStream<QueryResponseMessage>	PayloadConvertingQueryBusConnector.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)
MessageStream<QueryResponseMessage>	QueryBusConnector.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)	Sends the given query to the remote QueryBus.

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

Modifier and Type	Method	Description
CompletableFuture<Void>	DistributedQueryBus.completeSubscriptions(Predicate<QueryMessage> filter, ProcessingContext context)
CompletableFuture<Void>	DistributedQueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, ProcessingContext context)
CompletableFuture<Void>	DistributedQueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, ProcessingContext context)

Uses of QueryMessage in org.axonframework.messaging.queryhandling.interception

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

Modifier and Type	Method	Description
MessageStream<?>	QueryMessageHandlerInterceptorChain.proceed(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	InterceptingQueryBus.query(QueryMessage query, ProcessingContext context)
MessageStream<SubscriptionQueryUpdateMessage>	InterceptingQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize)
MessageStream<QueryResponseMessage>	InterceptingQueryBus.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)

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

Modifier and Type	Method	Description
CompletableFuture<Void>	InterceptingQueryBus.completeSubscriptions(Predicate<QueryMessage> filter, ProcessingContext context)
CompletableFuture<Void>	InterceptingQueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, ProcessingContext context)
CompletableFuture<Void>	InterceptingQueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, ProcessingContext context)

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

Modifier	Constructor	Description
	InterceptingQueryBus(QueryBus delegate, List<MessageHandlerInterceptor<? super QueryMessage>> handlerInterceptors, List<MessageDispatchInterceptor<? super QueryMessage>> dispatchInterceptors, List<MessageDispatchInterceptor<? super SubscriptionQueryUpdateMessage>> updateDispatchInterceptors)	Constructs a InterceptingQueryBus, delegating dispatching and handling logic to the given delegate.
	QueryMessageHandlerInterceptorChain(List<MessageHandlerInterceptor<? super QueryMessage>> interceptors, QueryHandler queryHandler)	Constructs a new QueryMessageHandlerInterceptorChain with a list of interception and an queryHandler.

Uses of QueryMessage in org.axonframework.messaging.queryhandling.tracing

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

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

Methods in org.axonframework.messaging.queryhandling.tracing 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.createStreamingQuerySpan(QueryMessage queryMessage, boolean distributed)
Span	QueryBusSpanFactory.createStreamingQuerySpan(QueryMessage queryMessage, boolean distributed)	Creates a span for a streaming query.
Span	DefaultQueryBusSpanFactory.createSubscriptionQueryProcessUpdateSpan(SubscriptionQueryUpdateMessage updateMessage, QueryMessage queryMessage)
Span	QueryBusSpanFactory.createSubscriptionQueryProcessUpdateSpan(SubscriptionQueryUpdateMessage updateMessage, QueryMessage queryMessage)	Creates a span for processing a subscription query update that has been received from the server.
Span	DefaultQueryBusSpanFactory.createSubscriptionQuerySpan(QueryMessage queryMessage, boolean distributed)
Span	QueryBusSpanFactory.createSubscriptionQuerySpan(QueryMessage queryMessage, boolean distributed)	Creates a span for a subscription query.