Uses of Interface
org.axonframework.messaging.queryhandling.SubscriptionQueryUpdateMessage
Packages that use SubscriptionQueryUpdateMessage
Package
Description
Part of the Axon Server Connector module.
Part of the Axon Messaging module.
Part of the Axon Messaging module.
Part of the Axon Messaging module.
Part of the Axon Messaging module.
Package for query handling components in Axon Framework.
Part of the Axon Messaging module.
Part of the Axon Messaging module.
Part of the Axon Messaging module.
-
Uses of SubscriptionQueryUpdateMessage in org.axonframework.axonserver.connector.query
Methods in org.axonframework.axonserver.connector.query that return SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionQueryConverter.convertQueryUpdate(io.axoniq.axonserver.grpc.query.QueryUpdate queryUpdate, @Nullable Converter converter) Converts aQueryUpdateobject into aSubscriptionQueryUpdateMessage.Methods in org.axonframework.axonserver.connector.query with parameters of type SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionstatic io.axoniq.axonserver.grpc.query.QueryUpdateQueryConverter.convertQueryUpdate(SubscriptionQueryUpdateMessage update) Converts aSubscriptionQueryUpdateMessageinto aQueryUpdate. -
Uses of SubscriptionQueryUpdateMessage in org.axonframework.messaging.core.configuration
Method parameters in org.axonframework.messaging.core.configuration with type arguments of type SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionMessagingConfigurer.registerSubscriptionQueryUpdateMonitor(ComponentBuilder<MessageMonitor<? super SubscriptionQueryUpdateMessage>> monitorBuilder) Registers a subscription query update monitor using the specifiedmonitorBuilder.MessagingConfigurer.registerSubscriptionQueryUpdateMonitor(MessageMonitorFactory<? super SubscriptionQueryUpdateMessage> monitorFactory) Registers amessage monitor factoryforsubscription-update-specificinfrastructure 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 SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionDefaultDispatchInterceptorRegistry.subscriptionQueryUpdateInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName) DispatchInterceptorRegistry.subscriptionQueryUpdateInterceptors(Configuration config, Class<?> componentType, @Nullable String componentName) Returns the list ofSubscriptionQueryUpdateMessage-specificMessageDispatchInterceptorsregistered in this registry for a specificcomponentTypeandcomponentName.Method parameters in org.axonframework.messaging.core.interception with type arguments of type SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionDefaultDispatchInterceptorRegistry.registerSubscriptionQueryUpdateInterceptor(ComponentBuilder<MessageDispatchInterceptor<? super SubscriptionQueryUpdateMessage>> interceptorBuilder) DefaultDispatchInterceptorRegistry.registerSubscriptionQueryUpdateInterceptor(DispatchInterceptorFactory<? super SubscriptionQueryUpdateMessage> interceptorFactory) DispatchInterceptorRegistry.registerSubscriptionQueryUpdateInterceptor(ComponentBuilder<MessageDispatchInterceptor<? super SubscriptionQueryUpdateMessage>> interceptorBuilder) Registers the giveninterceptorBuilderfor aSubscriptionQueryUpdateMessage-specificMessageDispatchInterceptor.DispatchInterceptorRegistry.registerSubscriptionQueryUpdateInterceptor(DispatchInterceptorFactory<? super SubscriptionQueryUpdateMessage> interceptorFactory) Registers the given component-awareinterceptorFactoryfor aSubscriptionQueryUpdateMessage-specificMessageDispatchInterceptor. -
Uses of SubscriptionQueryUpdateMessage in org.axonframework.messaging.monitoring.configuration
Methods in org.axonframework.messaging.monitoring.configuration that return types with arguments of type SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionDefaultMessageMonitorRegistry.subscriptionQueryUpdateMonitor(Configuration config, Class<?> componentType, @Nullable String componentName) MessageMonitorRegistry.subscriptionQueryUpdateMonitor(Configuration config, Class<?> componentType, @Nullable String componentName) Retrieves aMessageMonitorfor monitoring the processing ofSubscriptionQueryUpdateMessageinstances for a specificcomponentTypeandcomponentName.Method parameters in org.axonframework.messaging.monitoring.configuration with type arguments of type SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionDefaultMessageMonitorRegistry.registerSubscriptionQueryUpdateMonitor(ComponentBuilder<MessageMonitor<? super SubscriptionQueryUpdateMessage>> monitorBuilder) DefaultMessageMonitorRegistry.registerSubscriptionQueryUpdateMonitor(MessageMonitorFactory<? super SubscriptionQueryUpdateMessage> monitorFactory) MessageMonitorRegistry.registerSubscriptionQueryUpdateMonitor(ComponentBuilder<MessageMonitor<? super SubscriptionQueryUpdateMessage>> monitorBuilder) Registers aMessageMonitorspecifically forSubscriptionQueryUpdateMessagetypes using the providedComponentBuilder.MessageMonitorRegistry.registerSubscriptionQueryUpdateMonitor(MessageMonitorFactory<? super SubscriptionQueryUpdateMessage> monitorFactory) Registers a component-awareMessageMonitorspecifically for monitoring the processing ofSubscriptionQueryUpdateMessageinstances using the givenmonitorFactory. -
Uses of SubscriptionQueryUpdateMessage in org.axonframework.messaging.monitoring.interception
Methods in org.axonframework.messaging.monitoring.interception with parameters of type SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionMonitoringSubscriptionQueryUpdateDispatchInterceptor.interceptOnDispatch(SubscriptionQueryUpdateMessage message, @Nullable ProcessingContext context, MessageDispatchInterceptorChain<SubscriptionQueryUpdateMessage> interceptorChain) Method parameters in org.axonframework.messaging.monitoring.interception with type arguments of type SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionMonitoringSubscriptionQueryUpdateDispatchInterceptor.interceptOnDispatch(SubscriptionQueryUpdateMessage message, @Nullable ProcessingContext context, MessageDispatchInterceptorChain<SubscriptionQueryUpdateMessage> interceptorChain) Constructor parameters in org.axonframework.messaging.monitoring.interception with type arguments of type SubscriptionQueryUpdateMessageModifierConstructorDescriptionMonitoringSubscriptionQueryUpdateDispatchInterceptor(MessageMonitor<? super SubscriptionQueryUpdateMessage> messageMonitor) Constructs a new MonitoringSubscriptionQueryUpdateDispatchInterceptor using the givenMessageMonitor. -
Uses of SubscriptionQueryUpdateMessage in org.axonframework.messaging.queryhandling
Classes in org.axonframework.messaging.queryhandling that implement SubscriptionQueryUpdateMessageModifier and TypeClassDescriptionclassGeneric implementation of theSubscriptionQueryUpdateMessageinterface holding incremental update of a subscription query.Methods in org.axonframework.messaging.queryhandling that return SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionGenericSubscriptionQueryUpdateMessage.andMetadata(Map<String, String> metadata) SubscriptionQueryUpdateMessage.andMetadata(Map<String, String> metadata) GenericSubscriptionQueryUpdateMessage.withConvertedPayload(Type type, Converter converter) default SubscriptionQueryUpdateMessageSubscriptionQueryUpdateMessage.withConvertedPayload(Class<?> type, Converter converter) SubscriptionQueryUpdateMessage.withConvertedPayload(Type type, Converter converter) default SubscriptionQueryUpdateMessageSubscriptionQueryUpdateMessage.withConvertedPayload(TypeReference<?> type, Converter converter) GenericSubscriptionQueryUpdateMessage.withMetadata(Map<String, String> metadata) SubscriptionQueryUpdateMessage.withMetadata(Map<String, String> metadata) Methods in org.axonframework.messaging.queryhandling that return types with arguments of type SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize) Subscribes the givenquerywith the givenupdateBufferSize, and returns the MessageStream that provides the update of the subscription query.SimpleQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize) Method parameters in org.axonframework.messaging.queryhandling with type arguments of type SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionQueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, @Nullable ProcessingContext context) Emits the outcome of theupdateSuppliertosubscription queriesmatching the givenqueryNameand givenfilter.SimpleQueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, @Nullable ProcessingContext context) -
Uses of SubscriptionQueryUpdateMessage in org.axonframework.messaging.queryhandling.distributed
Methods in org.axonframework.messaging.queryhandling.distributed that return types with arguments of type SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionDistributedQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize) Methods in org.axonframework.messaging.queryhandling.distributed with parameters of type SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionQueryBusConnector.UpdateCallback.sendUpdate(SubscriptionQueryUpdateMessage update) Sends a subscription query update message asynchronously.Method parameters in org.axonframework.messaging.queryhandling.distributed with type arguments of type SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionDistributedQueryBus.emitUpdate(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 SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionInterceptingQueryBus.subscribeToUpdates(QueryMessage query, int updateBufferSize) Method parameters in org.axonframework.messaging.queryhandling.interception with type arguments of type SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionInterceptingQueryBus.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 with type parameters of type SubscriptionQueryUpdateMessageModifier and TypeMethodDescription<M extends SubscriptionQueryUpdateMessage>
MDefaultQueryUpdateEmitterSpanFactory.propagateContext(M update) <M extends SubscriptionQueryUpdateMessage>
MQueryUpdateEmitterSpanFactory.propagateContext(M update) Propagates the context of the current span to the given update message.Methods in org.axonframework.messaging.queryhandling.tracing with parameters of type SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionDefaultQueryBusSpanFactory.createSubscriptionQueryProcessUpdateSpan(SubscriptionQueryUpdateMessage updateMessage, QueryMessage queryMessage) QueryBusSpanFactory.createSubscriptionQueryProcessUpdateSpan(SubscriptionQueryUpdateMessage updateMessage, QueryMessage queryMessage) Creates a span for processing a subscription query update that has been received from the server.DefaultQueryUpdateEmitterSpanFactory.createUpdateEmitSpan(SubscriptionQueryUpdateMessage update) QueryUpdateEmitterSpanFactory.createUpdateEmitSpan(SubscriptionQueryUpdateMessage update) Creates a span for the actual emit of a query update when the UnitOfWork commits (or immediately if no UnitOfWork is active).DefaultQueryUpdateEmitterSpanFactory.createUpdateScheduleEmitSpan(SubscriptionQueryUpdateMessage update) QueryUpdateEmitterSpanFactory.createUpdateScheduleEmitSpan(SubscriptionQueryUpdateMessage update) Creates a span for the scheduling of emitting a query update.