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

Packages that use QueryMessage

Package	Description
org.axonframework.axonserver.connector.query	Part of the Axon Server Connector module.
org.axonframework.extension.reactor.messaging.core.interception	Part of the Axon Extension module.
org.axonframework.extension.reactor.messaging.queryhandling.gateway	Part of the Axon Extension module.
org.axonframework.messaging.core.configuration	Part of the Axon Messaging module.
org.axonframework.messaging.core.interception	Part of the Axon Messaging module.
org.axonframework.messaging.core.timeout	Part of the Axon Messaging module.
org.axonframework.messaging.monitoring.configuration	Part of the Axon Messaging module.
org.axonframework.messaging.monitoring.interception	Part of the Axon Messaging module.
org.axonframework.messaging.queryhandling	Package for query handling components in Axon Framework.
org.axonframework.messaging.queryhandling.annotation	Part of the Axon Messaging module.
org.axonframework.messaging.queryhandling.distributed	Part of the Axon Messaging module.
org.axonframework.messaging.queryhandling.interception	Part of the Axon Messaging module.
org.axonframework.messaging.queryhandling.tracing	Part of the Axon Messaging module.

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.convertSubscriptionQueryMessage(io.axoniq.axonserver.grpc.query.SubscriptionQuery query, @Nullable Converter converter)	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, @Nullable ProcessingContext context)
MessageStream<QueryResponseMessage>	AxonServerQueryBusConnector.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)

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

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

Modifier and Type	Method	Description
List<ReactorMessageDispatchInterceptor<? super QueryMessage>>	DefaultReactorDispatchInterceptorRegistry.queryInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName)
List<ReactorMessageDispatchInterceptor<? super QueryMessage>>	ReactorDispatchInterceptorRegistry.queryInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName)	Returns the list of ReactorMessageDispatchInterceptors registered for QueryMessages for a specific componentType and componentName.

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

Modifier and Type	Method	Description
ReactorDispatchInterceptorRegistry	DefaultReactorDispatchInterceptorRegistry.registerQueryInterceptor(ComponentBuilder<ReactorMessageDispatchInterceptor<? super QueryMessage>> interceptorBuilder)
ReactorDispatchInterceptorRegistry	DefaultReactorDispatchInterceptorRegistry.registerQueryInterceptor(ReactorDispatchInterceptorFactory<? super QueryMessage> interceptorFactory)
ReactorDispatchInterceptorRegistry	ReactorDispatchInterceptorRegistry.registerQueryInterceptor(ComponentBuilder<ReactorMessageDispatchInterceptor<? super QueryMessage>> interceptorBuilder)	Registers the given interceptorBuilder for a QueryMessage-specific ReactorMessageDispatchInterceptor.
ReactorDispatchInterceptorRegistry	ReactorDispatchInterceptorRegistry.registerQueryInterceptor(ReactorDispatchInterceptorFactory<? super QueryMessage> interceptorFactory)	Registers the given component-aware interceptorFactory for a QueryMessage-specific ReactorMessageDispatchInterceptor.

Uses of QueryMessage in org.axonframework.extension.reactor.messaging.queryhandling.gateway

Constructor parameters in org.axonframework.extension.reactor.messaging.queryhandling.gateway with type arguments of type QueryMessage

Modifier	Constructor	Description
	DefaultReactorQueryGateway(QueryGateway queryGateway, MessageTypeResolver messageTypeResolver, List<ReactorMessageDispatchInterceptor<? super QueryMessage>> dispatchInterceptors)	Instantiate a DefaultReactorQueryGateway.

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 builder in this Configurer.
MessagingConfigurer	MessagingConfigurer.registerQueryHandlerInterceptor(ComponentBuilder<MessageHandlerInterceptor<? super QueryMessage>> interceptorBuilder)	Registers the given QueryMessage MessageHandlerInterceptor builder in this Configurer.
MessagingConfigurer	MessagingConfigurer.registerQueryMonitor(ComponentBuilder<MessageMonitor<? super QueryMessage>> monitorBuilder)	Registers a query monitor using the specified monitorBuilder.
MessagingConfigurer	MessagingConfigurer.registerQueryMonitor(MessageMonitorFactory<? super QueryMessage> monitorFactory)	Registers a message monitor factory for query-specific infrastructure components in this configuration.

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, Class<?> componentType, @Nullable String componentName)
List<MessageHandlerInterceptor<? super QueryMessage>>	DefaultHandlerInterceptorRegistry.queryInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName)
List<MessageDispatchInterceptor<? super QueryMessage>>	DispatchInterceptorRegistry.queryInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName)	Returns the list of QueryMessage-specific MessageDispatchInterceptors registered in this registry for a specific componentType and componentName.
List<MessageHandlerInterceptor<? super QueryMessage>>	HandlerInterceptorRegistry.queryInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName)	Returns the list of QueryMessage-specific MessageHandlerInterceptors registered in this registry for a componentType and componentName.

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)
DispatchInterceptorRegistry	DefaultDispatchInterceptorRegistry.registerQueryInterceptor(DispatchInterceptorFactory<? super QueryMessage> interceptorFactory)
HandlerInterceptorRegistry	DefaultHandlerInterceptorRegistry.registerQueryInterceptor(ComponentBuilder<MessageHandlerInterceptor<? super QueryMessage>> interceptorBuilder)
HandlerInterceptorRegistry	DefaultHandlerInterceptorRegistry.registerQueryInterceptor(HandlerInterceptorFactory<? super QueryMessage> interceptorFactory)
DispatchInterceptorRegistry	DispatchInterceptorRegistry.registerQueryInterceptor(ComponentBuilder<MessageDispatchInterceptor<? super QueryMessage>> interceptorBuilder)	Registers the given interceptorBuilder for a QueryMessage-specific MessageDispatchInterceptor.
DispatchInterceptorRegistry	DispatchInterceptorRegistry.registerQueryInterceptor(DispatchInterceptorFactory<? super QueryMessage> interceptorFactory)	Registers the given component-aware interceptorFactory 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
HandlerInterceptorRegistry	HandlerInterceptorRegistry.registerQueryInterceptor(HandlerInterceptorFactory<? super QueryMessage> interceptorFactory)	Registers the given component-aware interceptorFactory 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, Class<?> componentType, @Nullable String componentName)
MessageMonitor<? super QueryMessage>	MessageMonitorRegistry.queryMonitor(Configuration config, Class<?> componentType, @Nullable String componentName)	Retrieves a MessageMonitor for monitoring the processing of QueryMessage instances for a specific componentType and componentName.

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	DefaultMessageMonitorRegistry.registerQueryMonitor(MessageMonitorFactory<? super QueryMessage> monitorFactory)
MessageMonitorRegistry	MessageMonitorRegistry.registerQueryMonitor(ComponentBuilder<MessageMonitor<? super QueryMessage>> monitorBuilder)	Registers a MessageMonitor specifically for QueryMessage types using the provided ComponentBuilder.
MessageMonitorRegistry	MessageMonitorRegistry.registerQueryMonitor(MessageMonitorFactory<? super QueryMessage> monitorFactory)	Registers a component-aware MessageMonitor specifically for monitoring the processing of QueryMessage instances using the given monitorFactory.

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,@Nullable String> metadata)
QueryMessage	QueryMessage.andMetadata(Map<String,@Nullable 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, @Nullable 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, @Nullable 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, @Nullable 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, @Nullable 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, @Nullable ProcessingContext context)	Completes subscription queries matching the given filter.
CompletableFuture<Void>	SimpleQueryBus.completeSubscriptions(Predicate<QueryMessage> filter, @Nullable ProcessingContext context)
CompletableFuture<Void>	QueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, @Nullable ProcessingContext context)	Completes subscription queries matching the given filter exceptionally with the given cause.
CompletableFuture<Void>	SimpleQueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, @Nullable ProcessingContext context)
CompletableFuture<Void>	QueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, @Nullable 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, @Nullable 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, @Nullable ProcessingContext context)
MessageStream<QueryResponseMessage>	DistributedQueryBus.query(QueryMessage query, @Nullable ProcessingContext context)
MessageStream<QueryResponseMessage>	PayloadConvertingQueryBusConnector.query(QueryMessage query, @Nullable ProcessingContext context)
MessageStream<QueryResponseMessage>	QueryBusConnector.Handler.query(QueryMessage query)	Handles the incoming query message.
MessageStream<QueryResponseMessage>	QueryBusConnector.query(QueryMessage query, @Nullable 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, @Nullable ProcessingContext context, int updateBufferSize)
MessageStream<QueryResponseMessage>	DistributedQueryBus.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)
MessageStream<QueryResponseMessage>	PayloadConvertingQueryBusConnector.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)
MessageStream<QueryResponseMessage>	QueryBusConnector.subscriptionQuery(QueryMessage query, @Nullable 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, @Nullable ProcessingContext context)
CompletableFuture<Void>	DistributedQueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, @Nullable ProcessingContext context)
CompletableFuture<Void>	DistributedQueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, @Nullable 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, @Nullable ProcessingContext context)
MessageStream<SubscriptionQueryUpdateMessage>	InterceptingQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize)
MessageStream<QueryResponseMessage>	InterceptingQueryBus.subscriptionQuery(QueryMessage query, @Nullable 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, @Nullable ProcessingContext context)
CompletableFuture<Void>	InterceptingQueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, @Nullable ProcessingContext context)
CompletableFuture<Void>	InterceptingQueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, @Nullable 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.