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, int updateBufferSize)
<Q,I,U> SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>>	AxonServerQueryBus.subscriptionQuery(SubscriptionQueryMessage<Q,I,U> query, SubscriptionQueryBackpressure backPressure, int updateBufferSize) Deprecated. in favor of using the {AxonServerQueryBus.subscriptionQuery(SubscriptionQueryMessage, int)}

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.

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

Constructor and Description
AxonServerSubscriptionQueryResult(SubscriptionQueryMessage<?,?,?> queryMessage, io.axoniq.axonserver.connector.query.SubscriptionQueryResult result, SubscriptionMessageSerializer subscriptionSerializer, QueryBusSpanFactory spanFactory, Span parentSpan) Instantiate a AxonServerSubscriptionQueryResult which will emit its initial response and the updates of the subscription query.

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
Span	QueryBusSpanFactory.createSubscriptionQueryProcessUpdateSpan(SubscriptionQueryUpdateMessage<?> updateMessage, SubscriptionQueryMessage<?,?,?> queryMessage) Creates a span for processing a subscription query update that has been received from the server.
Span	DefaultQueryBusSpanFactory.createSubscriptionQueryProcessUpdateSpan(SubscriptionQueryUpdateMessage<?> updateMessage, SubscriptionQueryMessage<?,?,?> queryMessage)
Span	QueryBusSpanFactory.createSubscriptionQuerySpan(SubscriptionQueryMessage<?,?,?> queryMessage, boolean distributed) Creates a span for a subscription query.
Span	DefaultQueryBusSpanFactory.createSubscriptionQuerySpan(SubscriptionQueryMessage<?,?,?> queryMessage, boolean distributed)
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, int updateBufferSize)
<U> UpdateHandlerRegistration<U>	QueryUpdateEmitter.registerUpdateHandler(SubscriptionQueryMessage<?,?,?> query, int updateBufferSize) Registers an Update Handler for given query with given updateBufferSize.
<U> UpdateHandlerRegistration<U>	SimpleQueryUpdateEmitter.registerUpdateHandler(SubscriptionQueryMessage<?,?,?> query, SubscriptionQueryBackpressure backpressure, int updateBufferSize) Deprecated. in favour of using {SimpleQueryUpdateEmitter.registerUpdateHandler(SubscriptionQueryMessage, int)}
<U> UpdateHandlerRegistration<U>	QueryUpdateEmitter.registerUpdateHandler(SubscriptionQueryMessage<?,?,?> query, SubscriptionQueryBackpressure backpressure, int updateBufferSize) Deprecated. in favour of using {QueryUpdateEmitter.registerUpdateHandler(SubscriptionQueryMessage, int)}
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, int updateBufferSize)
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.
<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)
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)}

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.