Uses of Interface
org.axonframework.queryhandling.SubscriptionQueryMessage

Packages that use SubscriptionQueryMessage

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

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

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

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 SubscriptionQueryMessage in org.axonframework.axonserver.connector.query.subscription

Classes in org.axonframework.axonserver.connector.query.subscription that implement SubscriptionQueryMessage

Modifier and Type	Class and Description
class	GrpcBackedSubscriptionQueryMessage<Q,I,U> Wrapper that allows clients to access a gRPC SubscriptionQuery message as a SubscriptionQueryMessage.

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

Modifier and Type	Method and Description
<Q,I,U> SubscriptionQueryMessage<Q,I,U>	SubscriptionMessageSerializer.deserialize(io.axoniq.axonserver.grpc.query.SubscriptionQuery subscriptionQuery) Deserializes the given subscriptionQuery into a SubscriptionQueryMessage.

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

Modifier and Type	Method and Description
io.axoniq.axonserver.grpc.query.SubscriptionQuery	SubscriptionMessageSerializer.serialize(SubscriptionQueryMessage<?,?,?> subscriptionQueryMessage) Deprecated. in through use of the AxonServer java connector
io.axoniq.axonserver.grpc.query.QueryRequest	SubscriptionMessageSerializer.serializeQuery(SubscriptionQueryMessage subscriptionQueryMessage) Serializes the given subscriptionQueryMessage into a QueryRequest.
io.axoniq.axonserver.grpc.SerializedObject	SubscriptionMessageSerializer.serializeUpdateType(SubscriptionQueryMessage<?,?,?> subscriptionQueryMessage) Serializes the given subscriptionQueryMessage into a SerializedObject.

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<?,?,?>>	SimpleQueryUpdateEmitter.activeSubscriptions()
default Set<SubscriptionQueryMessage<?,?,?>>	QueryUpdateEmitter.activeSubscriptions() Provides the set of running subscription queries.

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

Modifier and Type	Method and Description
boolean	SimpleQueryUpdateEmitter.queryUpdateHandlerRegistered(SubscriptionQueryMessage<?,?,?> query)
boolean	QueryUpdateEmitter.queryUpdateHandlerRegistered(SubscriptionQueryMessage<?,?,?> query) Checks whether there is a query update handler for a given query.
<U> UpdateHandlerRegistration<U>	SimpleQueryUpdateEmitter.registerUpdateHandler(SubscriptionQueryMessage<?,?,?> query, SubscriptionQueryBackpressure backpressure, int updateBufferSize)
<U> UpdateHandlerRegistration<U>	QueryUpdateEmitter.registerUpdateHandler(SubscriptionQueryMessage<?,?,?> query, SubscriptionQueryBackpressure backpressure, int updateBufferSize) Registers an Update Handler for given query with given backpressure and updateBufferSize.
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	SimpleQueryUpdateEmitter.complete(Predicate<SubscriptionQueryMessage<?,?,?>> filter)
void	QueryUpdateEmitter.complete(Predicate<SubscriptionQueryMessage<?,?,?>> filter) Completes subscription queries matching given filter.
void	SimpleQueryUpdateEmitter.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	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.
default <U> void	QueryUpdateEmitter.emit(Predicate<SubscriptionQueryMessage<?,?,U>> filter, U update) Emits given incremental update to subscription queries matching given filter.