Uses of Interface
org.axonframework.queryhandling.SubscriptionQueryMessage

Packages that use SubscriptionQueryMessage

Package	Description
org.axonframework.queryhandling

Uses of SubscriptionQueryMessage in org.axonframework.queryhandling

Classes in org.axonframework.queryhandling that implement SubscriptionQueryMessage

Modifier and Type	Class and Description
class	GenericSubscriptionQueryMessage<Q,I,U> Generic implementation of the SubscriptionQueryMessage.

Methods in org.axonframework.queryhandling that return SubscriptionQueryMessage

Modifier and Type	Method and Description
SubscriptionQueryMessage<Q,I,U>	SubscriptionQueryMessage.andMetaData(Map<String,?> additionalMetaData) Returns a copy of this SubscriptionQueryMessage with its MetaData merged with given metaData.
SubscriptionQueryMessage<Q,I,U>	SubscriptionQueryMessage.withMetaData(Map<String,?> metaData) Returns a copy of this SubscriptionQueryMessage with the given metaData.

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

Modifier and Type	Method and Description
Set<SubscriptionQueryMessage<?,?,?>>	SimpleQueryBus.activeSubscriptions() Provides the set of running subscription queries.

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

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.

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

Modifier and Type	Method and Description
void	SimpleQueryBus.complete(Predicate<SubscriptionQueryMessage<?,?,?>> filter)
void	QueryUpdateEmitter.complete(Predicate<SubscriptionQueryMessage<?,?,?>> filter) Completes subscription queries matching given filter.
void	SimpleQueryBus.completeExceptionally(Predicate<SubscriptionQueryMessage<?,?,?>> filter, Throwable cause)
void	QueryUpdateEmitter.completeExceptionally(Predicate<SubscriptionQueryMessage<?,?,?>> filter, Throwable cause) Completes with an error subscription queries matching given 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.
default <U> void	QueryUpdateEmitter.emit(Predicate<SubscriptionQueryMessage<?,?,U>> filter, U update) Emits given incremental update to subscription queries matching given filter.