Uses of Interface
org.axonframework.queryhandling.SubscriptionQueryUpdateMessage

Packages that use SubscriptionQueryUpdateMessage

Package	Description
org.axonframework.queryhandling

Uses of SubscriptionQueryUpdateMessage in org.axonframework.queryhandling

Classes in org.axonframework.queryhandling that implement SubscriptionQueryUpdateMessage

Modifier and Type	Class	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	Description
<T, M extends SubscriptionQueryUpdateMessage<T>> M	DefaultQueryUpdateEmitterSpanFactory.propagateContext(M update)
<T, M extends SubscriptionQueryUpdateMessage<T>> M	QueryUpdateEmitterSpanFactory.propagateContext(M update)	Propagates the context of the current span to the given update message.

Methods in org.axonframework.queryhandling that return SubscriptionQueryUpdateMessage

Modifier and Type	Method	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	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.
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.
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)}
<Q, I, U> SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>>	SimpleQueryBus.subscriptionQuery(SubscriptionQueryMessage<Q,I,U> query, int updateBufferSize)
<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)

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

Modifier and Type	Method	Description
Span	DefaultQueryBusSpanFactory.createSubscriptionQueryProcessUpdateSpan(SubscriptionQueryUpdateMessage<?> updateMessage, SubscriptionQueryMessage<?,?,?> queryMessage)
Span	QueryBusSpanFactory.createSubscriptionQueryProcessUpdateSpan(SubscriptionQueryUpdateMessage<?> updateMessage, SubscriptionQueryMessage<?,?,?> queryMessage)	Creates a span for processing a subscription query update that has been received from the server.
Span	DefaultQueryUpdateEmitterSpanFactory.createUpdateEmitSpan(SubscriptionQueryUpdateMessage<?> update)
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.createUpdateScheduleEmitSpan(SubscriptionQueryUpdateMessage<?> update)
Span	QueryUpdateEmitterSpanFactory.createUpdateScheduleEmitSpan(SubscriptionQueryUpdateMessage<?> update)	Creates a span for the scheduling of emitting a query 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	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.
<U> void	SimpleQueryUpdateEmitter.emit(Predicate<SubscriptionQueryMessage<?,?,U>> filter, SubscriptionQueryUpdateMessage<U> update)

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

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

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