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

Packages that use QueryMessage

Package	Description
io.axoniq.framework.axonserver.connector.query	Part of the Axon Server Connector module.
io.axoniq.framework.messaging.multitenancy.axonserver.queryhandling	Part of the Axoniq Framework multi-tenancy module.
io.axoniq.framework.messaging.multitenancy.queryhandling	Package containing multitenancy support for query components.
io.axoniq.framework.messaging.queryhandling.distributed	Part of the Axon Messaging module.
io.axoniq.framework.messaging.queryhandling.distributed.tracing	Internal delegating tracing decorator for the distributed QueryBusConnector.
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.configuration	Part of the Axon Messaging module.
org.axonframework.messaging.queryhandling.interception	Part of the Axon Messaging module.
org.axonframework.messaging.queryhandling.tracing	Tracing decorators for query handling components.

Uses of QueryMessage in io.axoniq.framework.axonserver.connector.query

Methods in io.axoniq.framework.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 io.axoniq.framework.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 io.axoniq.framework.messaging.multitenancy.axonserver.queryhandling

Methods in io.axoniq.framework.messaging.multitenancy.axonserver.queryhandling with parameters of type QueryMessage

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	MultiTenantAxonServerQueryBusConnector.query(QueryMessage query, @Nullable ProcessingContext context)	Resolves the connector for the current tenant and subsequently dispatches the given query to it.
MessageStream<QueryResponseMessage>	MultiTenantAxonServerQueryBusConnector.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)	Resolves the connector for the current tenant and subsequently dispatches the given subscription query to it.

Uses of QueryMessage in io.axoniq.framework.messaging.multitenancy.queryhandling

Methods in io.axoniq.framework.messaging.multitenancy.queryhandling with parameters of type QueryMessage

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	TenantAwareQueryBus.query(QueryMessage query, @Nullable ProcessingContext context)	Dispatches the given query for the tenant resolved from it.
MessageStream<SubscriptionQueryUpdateMessage>	TenantAwareQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize)
MessageStream<QueryResponseMessage>	TenantAwareQueryBus.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)

Method parameters in io.axoniq.framework.messaging.multitenancy.queryhandling with type arguments of type QueryMessage

Modifier and Type	Method	Description
CompletableFuture<Void>	TenantAwareQueryBus.completeSubscriptions(Predicate<QueryMessage> filter, @Nullable ProcessingContext context)	Completes subscription queries matching the given filter.
CompletableFuture<OptionalInt>	TenantAwareQueryBus.completeSubscriptionsAndCount(Predicate<QueryMessage> filter, @Nullable ProcessingContext context)	Completes subscription queries matching the given filter, returning the number of subscription queries that were completed.
CompletableFuture<Void>	TenantAwareQueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, @Nullable ProcessingContext context)	Completes subscription queries matching the given filter exceptionally with the given cause.
CompletableFuture<OptionalInt>	TenantAwareQueryBus.completeSubscriptionsExceptionallyAndCount(Predicate<QueryMessage> filter, Throwable cause, @Nullable ProcessingContext context)	Completes subscription queries matching the given filter exceptionally with the given cause, returning the number of subscription queries that were completed exceptionally.
CompletableFuture<Void>	TenantAwareQueryBus.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<OptionalInt>	TenantAwareQueryBus.emitUpdateAndCount(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, returning the number of subscription queries the update was emitted to.

Uses of QueryMessage in io.axoniq.framework.messaging.queryhandling.distributed

Methods in io.axoniq.framework.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 io.axoniq.framework.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<OptionalInt>	DistributedQueryBus.completeSubscriptionsAndCount(Predicate<QueryMessage> filter, @Nullable ProcessingContext context)
CompletableFuture<Void>	DistributedQueryBus.completeSubscriptionsExceptionally(Predicate<QueryMessage> filter, Throwable cause, @Nullable ProcessingContext context)
CompletableFuture<OptionalInt>	DistributedQueryBus.completeSubscriptionsExceptionallyAndCount(Predicate<QueryMessage> filter, Throwable cause, @Nullable ProcessingContext context)
CompletableFuture<Void>	DistributedQueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, @Nullable ProcessingContext context)
CompletableFuture<OptionalInt>	DistributedQueryBus.emitUpdateAndCount(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, @Nullable ProcessingContext context)

Uses of QueryMessage in io.axoniq.framework.messaging.queryhandling.distributed.tracing

Methods in io.axoniq.framework.messaging.queryhandling.distributed.tracing with parameters of type QueryMessage

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	TracingQueryBusConnector.query(QueryMessage query, @Nullable ProcessingContext context)
MessageStream<QueryResponseMessage>	TracingQueryBusConnector.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>	QueryHandlingExceptionHandler.handle(QueryMessage query, ProcessingContext context, Throwable error)	Called when a query handler throws an exception.
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)
default CompletableFuture<OptionalInt>	QueryBus.completeSubscriptionsAndCount(Predicate<QueryMessage> filter, @Nullable ProcessingContext context)	Completes subscription queries matching the given filter, returning the number of subscription queries that were completed.
CompletableFuture<OptionalInt>	SimpleQueryBus.completeSubscriptionsAndCount(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)
default CompletableFuture<OptionalInt>	QueryBus.completeSubscriptionsExceptionallyAndCount(Predicate<QueryMessage> filter, Throwable cause, @Nullable ProcessingContext context)	Completes subscription queries matching the given filter exceptionally with the given cause, returning the number of subscription queries that were completed exceptionally.
CompletableFuture<OptionalInt>	SimpleQueryBus.completeSubscriptionsExceptionallyAndCount(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)
default CompletableFuture<OptionalInt>	QueryBus.emitUpdateAndCount(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, returning the number of subscription queries the update was emitted to.
CompletableFuture<OptionalInt>	SimpleQueryBus.emitUpdateAndCount(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.configuration

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

Modifier and Type	Method	Description
QueryHandlingModule.QueryHandlerPhase	QueryHandlingModule.QueryHandlerPhase.intercepted(ComponentBuilder<MessageHandlerInterceptor<? super QueryMessage>> interceptorBuilder)	Registers an interceptor to be applied to the query handling component assembled by this module.
default QueryHandlingModule.QueryHandlerPhase	QueryHandlingModule.QueryHandlerPhase.withExceptionHandler(ComponentBuilder<? extends MessageHandlingExceptionHandler<? super QueryMessage>> handlerBuilder)	Wraps the query handling component with the exception handler built by the given handlerBuilder.

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<QueryResponseMessage>	InterceptingQueryHandlingComponent.handle(QueryMessage query, ProcessingContext processingContext)
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.
	InterceptingQueryHandlingComponent(List<MessageHandlerInterceptor<? super QueryMessage>> interceptors, QueryHandlingComponent delegate)	Constructs a new InterceptingQueryHandlingComponent wrapping the given delegate with the given interceptors.
	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 parameters of type QueryMessage

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	TracingQueryBus.query(QueryMessage query, @Nullable ProcessingContext context)
MessageStream<SubscriptionQueryUpdateMessage>	TracingQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize)
MessageStream<QueryResponseMessage>	TracingQueryBus.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)

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

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