Uses of Interface
org.axonframework.messaging.queryhandling.SubscriptionQueryUpdateMessage
Packages that use SubscriptionQueryUpdateMessage
Package
Description
-
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) 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>> messageMonitorBuilder) Registers a subscription query update monitor using the specifiedmessageMonitorBuilder. -
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) DispatchInterceptorRegistry.subscriptionQueryUpdateInterceptors(Configuration config) Returns the list ofSubscriptionQueryUpdateMessage-specificMessageDispatchInterceptorsregistered in this registry.Method parameters in org.axonframework.messaging.core.interception with type arguments of type SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionDefaultDispatchInterceptorRegistry.registerSubscriptionQueryUpdateInterceptor(ComponentBuilder<MessageDispatchInterceptor<? super SubscriptionQueryUpdateMessage>> interceptorBuilder) DispatchInterceptorRegistry.registerSubscriptionQueryUpdateInterceptor(ComponentBuilder<MessageDispatchInterceptor<? super SubscriptionQueryUpdateMessage>> interceptorBuilder) Registers the giveninterceptorBuilderfor 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) MessageMonitorRegistry.subscriptionQueryUpdateMonitor(Configuration config) Retrieves aMessageMonitorfor monitoring the processing ofSubscriptionQueryUpdateMessageinstances.Method parameters in org.axonframework.messaging.monitoring.configuration with type arguments of type SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionDefaultMessageMonitorRegistry.registerSubscriptionQueryUpdateMonitor(ComponentBuilder<MessageMonitor<? super SubscriptionQueryUpdateMessage>> monitorBuilder) MessageMonitorRegistry.registerSubscriptionQueryUpdateMonitor(ComponentBuilder<MessageMonitor<? super SubscriptionQueryUpdateMessage>> monitorBuilder) Registers aMessageMonitorspecifically forSubscriptionQueryUpdateMessagetypes using the providedComponentBuilder. -
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, ProcessingContext context, MessageDispatchInterceptorChain<SubscriptionQueryUpdateMessage> interceptorChain) Method parameters in org.axonframework.messaging.monitoring.interception with type arguments of type SubscriptionQueryUpdateMessageModifier and TypeMethodDescriptionMonitoringSubscriptionQueryUpdateDispatchInterceptor.interceptOnDispatch(SubscriptionQueryUpdateMessage message, 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, ProcessingContext context) Emits the outcome of theupdateSuppliertosubscription queriesmatching the givenqueryNameand givenfilter.SimpleQueryBus.emitUpdate(Predicate<QueryMessage> filter, Supplier<SubscriptionQueryUpdateMessage> updateSupplier, 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, 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, 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.