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 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>	SubscriptionQueryUpdateMessage.andMetaData(Map<String,?> metaData)
SubscriptionQueryUpdateMessage<U>	GenericSubscriptionQueryUpdateMessage.andMetaData(Map<String,?> metaData)
static <T> SubscriptionQueryUpdateMessage<T>	GenericSubscriptionQueryUpdateMessage.asUpdateMessage(Object payload) Creates GenericSubscriptionQueryUpdateMessage from provided payload which represents incremental update.
SubscriptionQueryUpdateMessage<U>	SubscriptionQueryUpdateMessage.withMetaData(Map<String,?> metaData)
SubscriptionQueryUpdateMessage<U>	GenericSubscriptionQueryUpdateMessage.withMetaData(Map<String,?> metaData)

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

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

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

Constructor and Description
SimpleQueryBus(MessageMonitor<? super QueryMessage<?,?>> messageMonitor, MessageMonitor<? super SubscriptionQueryUpdateMessage<?>> updateMessageMonitor, TransactionManager transactionManager, QueryInvocationErrorHandler errorHandler) Initialize the query bus with the given messageMonitor, updateMessageMonitor, transactionManager and given errorHandler.