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, SubscriptionQueryBackpressure backPressure, int updateBufferSize)

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

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()

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 that return SubscriptionQueryUpdateMessage

Modifier and Type	Method and Description
SubscriptionQueryUpdateMessage<U>	GenericSubscriptionQueryUpdateMessage.andMetaData(Map<String,?> metaData)
SubscriptionQueryUpdateMessage<U>	SubscriptionQueryUpdateMessage.andMetaData(Map<String,?> metaData)
static <T> SubscriptionQueryUpdateMessage<T>	GenericSubscriptionQueryUpdateMessage.asUpdateMessage(Object payload) Creates GenericSubscriptionQueryUpdateMessage from provided payload which represents incremental update.
SubscriptionQueryUpdateMessage<U>	GenericSubscriptionQueryUpdateMessage.withMetaData(Map<String,?> metaData)
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, SubscriptionQueryBackpressure backpressure, int updateBufferSize)
default <Q,I,U> SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>>	QueryBus.subscriptionQuery(SubscriptionQueryMessage<Q,I,U> query, SubscriptionQueryBackpressure backpressure, int updateBufferSize) Dispatch the given query to a single QueryHandler subscribed to the given query's queryName/initialResponseType/updateResponseType.

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

Modifier and Type	Method and Description
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) Constructs a UpdateHandlerRegistration with given registration and updates.