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

Packages that use SubscriptionQueryUpdateMessage

Package	Description
io.axoniq.framework.axonserver.connector.query	Part of the Axon Server Connector 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.
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.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.interception	Part of the Axon Messaging module.
org.axonframework.messaging.queryhandling.tracing	Tracing decorators for query handling components.

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

Methods in io.axoniq.framework.axonserver.connector.query that return SubscriptionQueryUpdateMessage

Modifier and Type	Method	Description
static SubscriptionQueryUpdateMessage	QueryConverter.convertQueryUpdate(io.axoniq.axonserver.grpc.query.QueryUpdate queryUpdate, @Nullable Converter converter)	Converts a QueryUpdate object into a SubscriptionQueryUpdateMessage.

Methods in io.axoniq.framework.axonserver.connector.query with parameters of type SubscriptionQueryUpdateMessage

Modifier and Type	Method	Description
static io.axoniq.axonserver.grpc.query.QueryUpdate	QueryConverter.convertQueryUpdate(SubscriptionQueryUpdateMessage update)	Converts a SubscriptionQueryUpdateMessage into a QueryUpdate.

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

Methods in io.axoniq.framework.messaging.multitenancy.queryhandling that return types with arguments of type SubscriptionQueryUpdateMessage

Modifier and Type	Method	Description
MessageStream<SubscriptionQueryUpdateMessage>	TenantAwareQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize)

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

Modifier and Type	Method	Description
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 SubscriptionQueryUpdateMessage in io.axoniq.framework.messaging.queryhandling.distributed

Methods in io.axoniq.framework.messaging.queryhandling.distributed that return types with arguments of type SubscriptionQueryUpdateMessage

Modifier and Type	Method	Description
MessageStream<SubscriptionQueryUpdateMessage>	DistributedQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize)

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

Modifier and Type	Method	Description
CompletableFuture<Void>	QueryBusConnector.UpdateCallback.sendUpdate(SubscriptionQueryUpdateMessage update)	Sends a subscription query update message asynchronously.

Method parameters in io.axoniq.framework.messaging.queryhandling.distributed with type arguments of type SubscriptionQueryUpdateMessage

Modifier and Type	Method	Description
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 SubscriptionQueryUpdateMessage in org.axonframework.messaging.core.configuration

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

Modifier and Type	Method	Description
MessagingConfigurer	MessagingConfigurer.registerSubscriptionQueryUpdateMonitor(ComponentBuilder<MessageMonitor<? super SubscriptionQueryUpdateMessage>> monitorBuilder)	Registers a subscription query update monitor using the specified monitorBuilder.
MessagingConfigurer	MessagingConfigurer.registerSubscriptionQueryUpdateMonitor(MessageMonitorFactory<? super SubscriptionQueryUpdateMessage> monitorFactory)	Registers a message monitor factory for subscription-update-specific infrastructure components in this configuration.

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

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

Modifier and Type	Method	Description
List<MessageDispatchInterceptor<? super SubscriptionQueryUpdateMessage>>	DefaultDispatchInterceptorRegistry.subscriptionQueryUpdateInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName)
List<MessageDispatchInterceptor<? super SubscriptionQueryUpdateMessage>>	DispatchInterceptorRegistry.subscriptionQueryUpdateInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName)	Returns the list of SubscriptionQueryUpdateMessage-specific MessageDispatchInterceptors registered in this registry for a specific componentType and componentName.

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

Modifier and Type	Method	Description
DispatchInterceptorRegistry	DefaultDispatchInterceptorRegistry.registerSubscriptionQueryUpdateInterceptor(ComponentBuilder<MessageDispatchInterceptor<? super SubscriptionQueryUpdateMessage>> interceptorBuilder)
DispatchInterceptorRegistry	DefaultDispatchInterceptorRegistry.registerSubscriptionQueryUpdateInterceptor(DispatchInterceptorFactory<? super SubscriptionQueryUpdateMessage> interceptorFactory)
DispatchInterceptorRegistry	DispatchInterceptorRegistry.registerSubscriptionQueryUpdateInterceptor(ComponentBuilder<MessageDispatchInterceptor<? super SubscriptionQueryUpdateMessage>> interceptorBuilder)	Registers the given interceptorBuilder for a SubscriptionQueryUpdateMessage-specific MessageDispatchInterceptor.
DispatchInterceptorRegistry	DispatchInterceptorRegistry.registerSubscriptionQueryUpdateInterceptor(DispatchInterceptorFactory<? super SubscriptionQueryUpdateMessage> interceptorFactory)	Registers the given component-aware interceptorFactory for a SubscriptionQueryUpdateMessage-specific MessageDispatchInterceptor.

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

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

Modifier and Type	Method	Description
MessageMonitor<? super SubscriptionQueryUpdateMessage>	DefaultMessageMonitorRegistry.subscriptionQueryUpdateMonitor(Configuration config, Class<?> componentType, @Nullable String componentName)
MessageMonitor<? super SubscriptionQueryUpdateMessage>	MessageMonitorRegistry.subscriptionQueryUpdateMonitor(Configuration config, Class<?> componentType, @Nullable String componentName)	Retrieves a MessageMonitor for monitoring the processing of SubscriptionQueryUpdateMessage instances for a specific componentType and componentName.

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

Modifier and Type	Method	Description
MessageMonitorRegistry	DefaultMessageMonitorRegistry.registerSubscriptionQueryUpdateMonitor(ComponentBuilder<MessageMonitor<? super SubscriptionQueryUpdateMessage>> monitorBuilder)
MessageMonitorRegistry	DefaultMessageMonitorRegistry.registerSubscriptionQueryUpdateMonitor(MessageMonitorFactory<? super SubscriptionQueryUpdateMessage> monitorFactory)
MessageMonitorRegistry	MessageMonitorRegistry.registerSubscriptionQueryUpdateMonitor(ComponentBuilder<MessageMonitor<? super SubscriptionQueryUpdateMessage>> monitorBuilder)	Registers a MessageMonitor specifically for SubscriptionQueryUpdateMessage types using the provided ComponentBuilder.
MessageMonitorRegistry	MessageMonitorRegistry.registerSubscriptionQueryUpdateMonitor(MessageMonitorFactory<? super SubscriptionQueryUpdateMessage> monitorFactory)	Registers a component-aware MessageMonitor specifically for monitoring the processing of SubscriptionQueryUpdateMessage instances using the given monitorFactory.

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

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

Modifier and Type	Method	Description
MessageStream<?>	MonitoringSubscriptionQueryUpdateDispatchInterceptor.interceptOnDispatch(SubscriptionQueryUpdateMessage message, @Nullable ProcessingContext context, MessageDispatchInterceptorChain<SubscriptionQueryUpdateMessage> interceptorChain)

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

Modifier and Type	Method	Description
MessageStream<?>	MonitoringSubscriptionQueryUpdateDispatchInterceptor.interceptOnDispatch(SubscriptionQueryUpdateMessage message, @Nullable ProcessingContext context, MessageDispatchInterceptorChain<SubscriptionQueryUpdateMessage> interceptorChain)

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

Modifier	Constructor	Description
	MonitoringSubscriptionQueryUpdateDispatchInterceptor(MessageMonitor<? super SubscriptionQueryUpdateMessage> messageMonitor)	Constructs a new MonitoringSubscriptionQueryUpdateDispatchInterceptor using the given MessageMonitor.

Uses of SubscriptionQueryUpdateMessage in org.axonframework.messaging.queryhandling

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

Modifier and Type	Class	Description
class	GenericSubscriptionQueryUpdateMessage	Generic implementation of the SubscriptionQueryUpdateMessage interface holding incremental update of a subscription query.

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

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

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

Modifier and Type	Method	Description
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)

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

Modifier and Type	Method	Description
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 SubscriptionQueryUpdateMessage in org.axonframework.messaging.queryhandling.interception

Methods in org.axonframework.messaging.queryhandling.interception that return types with arguments of type SubscriptionQueryUpdateMessage

Modifier and Type	Method	Description
MessageStream<SubscriptionQueryUpdateMessage>	InterceptingQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize)

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

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

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

Methods in org.axonframework.messaging.queryhandling.tracing that return types with arguments of type SubscriptionQueryUpdateMessage

Modifier and Type	Method	Description
MessageStream<SubscriptionQueryUpdateMessage>	TracingQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize)

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

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