Uses of Interface
org.axonframework.queryhandling.SubscriptionQueryUpdateMessage

Packages that use SubscriptionQueryUpdateMessage

Package	Description
org.axonframework.axonserver.connector.query
org.axonframework.axonserver.connector.query.subscription
org.axonframework.queryhandling

Uses of SubscriptionQueryUpdateMessage in org.axonframework.axonserver.connector.query

Methods in org.axonframework.axonserver.connector.query that return types with arguments of type SubscriptionQueryUpdateMessage

Modifier and Type	Method and Description
<Q,I,U> SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>>	AxonServerQueryBus.subscriptionQuery(SubscriptionQueryMessage<Q,I,U> query, int updateBufferSize)
<Q,I,U> SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>>	AxonServerQueryBus.subscriptionQuery(SubscriptionQueryMessage<Q,I,U> query, SubscriptionQueryBackpressure backPressure, int updateBufferSize) Deprecated. in favor of using the {AxonServerQueryBus.subscriptionQuery(SubscriptionQueryMessage, int)}

Uses of SubscriptionQueryUpdateMessage in org.axonframework.axonserver.connector.query.subscription

Methods in org.axonframework.axonserver.connector.query.subscription that return SubscriptionQueryUpdateMessage

Modifier and Type	Method and Description
<U> SubscriptionQueryUpdateMessage<U>	SubscriptionMessageSerializer.deserialize(io.axoniq.axonserver.grpc.query.QueryUpdate queryUpdate) Deserializes the given queryUpdate into a SubscriptionQueryUpdateMessage.

Methods in org.axonframework.axonserver.connector.query.subscription that return types with arguments of type SubscriptionQueryUpdateMessage

Modifier and Type	Method and Description
reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>>	DeserializedResult.updates() Deprecated.
reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>>	AxonServerSubscriptionQueryResult.updates()

Methods in org.axonframework.axonserver.connector.query.subscription with parameters of type SubscriptionQueryUpdateMessage

Modifier and Type	Method and Description
io.axoniq.axonserver.grpc.query.QueryUpdate	SubscriptionMessageSerializer.serialize(SubscriptionQueryUpdateMessage<?> subscriptionQueryUpdateMessage) Serializes the given subscriptionQueryUpdateMessage into a QueryUpdate.

Uses of SubscriptionQueryUpdateMessage in org.axonframework.queryhandling

Classes in org.axonframework.queryhandling that implement SubscriptionQueryUpdateMessage

Modifier and Type	Class and Description
class	GenericSubscriptionQueryUpdateMessage<U> Generic SubscriptionQueryUpdateMessage which holds incremental update of an subscription query.

Methods in org.axonframework.queryhandling with type parameters of type SubscriptionQueryUpdateMessage

Modifier and Type	Method and Description
<T,M extends SubscriptionQueryUpdateMessage<T>> M	QueryUpdateEmitterSpanFactory.propagateContext(M update) Propagates the context of the current span to the given update message.
<T,M extends SubscriptionQueryUpdateMessage<T>> M	DefaultQueryUpdateEmitterSpanFactory.propagateContext(M update)

Methods in org.axonframework.queryhandling that return SubscriptionQueryUpdateMessage

Modifier and Type	Method and Description
SubscriptionQueryUpdateMessage<U>	SubscriptionQueryUpdateMessage.andMetaData(Map<String,?> metaData)
static <T> SubscriptionQueryUpdateMessage<T>	GenericSubscriptionQueryUpdateMessage.asUpdateMessage(Class<T> declaredType, Throwable exception) Creates a GenericSubscriptionQueryUpdateMessage with the given declaredType and exception result.
static <T> SubscriptionQueryUpdateMessage<T>	GenericSubscriptionQueryUpdateMessage.asUpdateMessage(Object payload) Creates GenericSubscriptionQueryUpdateMessage from provided payload which represents incremental update.
SubscriptionQueryUpdateMessage<U>	SubscriptionQueryUpdateMessage.withMetaData(Map<String,?> metaData)

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

Modifier and Type	Method and Description
reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>>	UpdateHandlerRegistration.getUpdates() Gets the updates.
default <Q,I,U> SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>>	QueryBus.subscriptionQuery(SubscriptionQueryMessage<Q,I,U> query) Dispatch the given query to a single QueryHandler subscribed to the given query's queryName/initialResponseType/updateResponseType.
<Q,I,U> SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>>	SimpleQueryBus.subscriptionQuery(SubscriptionQueryMessage<Q,I,U> query, int updateBufferSize)
default <Q,I,U> SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>>	QueryBus.subscriptionQuery(SubscriptionQueryMessage<Q,I,U> query, int updateBufferSize) Dispatch the given query to a single QueryHandler subscribed to the given query's queryName/initialResponseType/updateResponseType.
<Q,I,U> SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>>	SimpleQueryBus.subscriptionQuery(SubscriptionQueryMessage<Q,I,U> query, SubscriptionQueryBackpressure backpressure, int updateBufferSize) Deprecated. in favor use of {SimpleQueryBus.subscriptionQuery(SubscriptionQueryMessage, int)
default <Q,I,U> SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>>	QueryBus.subscriptionQuery(SubscriptionQueryMessage<Q,I,U> query, SubscriptionQueryBackpressure backpressure, int updateBufferSize) Deprecated. in favour of using {QueryBus.subscriptionQuery(SubscriptionQueryMessage, int)}

Methods in org.axonframework.queryhandling with parameters of type SubscriptionQueryUpdateMessage

Modifier and Type	Method and Description
Span	QueryBusSpanFactory.createSubscriptionQueryProcessUpdateSpan(SubscriptionQueryUpdateMessage<?> updateMessage, SubscriptionQueryMessage<?,?,?> queryMessage) Creates a span for processing a subscription query update that has been received from the server.
Span	DefaultQueryBusSpanFactory.createSubscriptionQueryProcessUpdateSpan(SubscriptionQueryUpdateMessage<?> updateMessage, SubscriptionQueryMessage<?,?,?> queryMessage)
Span	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).
Span	DefaultQueryUpdateEmitterSpanFactory.createUpdateEmitSpan(SubscriptionQueryUpdateMessage<?> update)
Span	QueryUpdateEmitterSpanFactory.createUpdateScheduleEmitSpan(SubscriptionQueryUpdateMessage<?> update) Creates a span for the scheduling of emitting a query update.
Span	DefaultQueryUpdateEmitterSpanFactory.createUpdateScheduleEmitSpan(SubscriptionQueryUpdateMessage<?> update)
default <Q,U> void	QueryUpdateEmitter.emit(Class<Q> queryType, Predicate<? super Q> filter, SubscriptionQueryUpdateMessage<U> update) Emits given incremental update to subscription queries matching given query type and filter.
<U> void	SimpleQueryUpdateEmitter.emit(Predicate<SubscriptionQueryMessage<?,?,U>> filter, SubscriptionQueryUpdateMessage<U> update)
<U> void	QueryUpdateEmitter.emit(Predicate<SubscriptionQueryMessage<?,?,U>> filter, SubscriptionQueryUpdateMessage<U> update) Emits incremental update (as return value of provided update function) to subscription queries matching given filter.

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

Modifier and Type	Method and Description
Registration	SimpleQueryUpdateEmitter.registerDispatchInterceptor(MessageDispatchInterceptor<? super SubscriptionQueryUpdateMessage<?>> interceptor)
SimpleQueryUpdateEmitter.Builder	SimpleQueryUpdateEmitter.Builder.updateMessageMonitor(MessageMonitor<? super SubscriptionQueryUpdateMessage<?>> updateMessageMonitor) Sets the MessageMonitor used to monitor SubscriptionQueryUpdateMessages being processed.

Constructor parameters in org.axonframework.queryhandling with type arguments of type SubscriptionQueryUpdateMessage

Constructor and Description
UpdateHandlerRegistration(Registration registration, reactor.core.publisher.Flux<SubscriptionQueryUpdateMessage<U>> updates, Runnable completeHandler) Constructs a UpdateHandlerRegistration with given registration and updates.