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

Class Summary

Class	Description
AxonServerSubscriptionQueryResult	A SubscriptionQueryResult that emits initial response and update when subscription query response message is received.
DeserializedResult<I,U>	A decorator of the SubscriptionQueryUpdateMessage to deserialize a QueryResponseMessage and QueryUpdate messages.
DisposableResult<I,U>	A decorator of the SubscriptionQueryResult which adds the DisposableResult.cancel() operation.
GrpcBackedSubscriptionQueryMessage<Q,I,U>	Wrapper that allows clients to access a gRPC SubscriptionQuery message as a SubscriptionQueryMessage.
SubscriptionMessageSerializer	Converter between Axon Framework SubscriptionQueryMessage, the initial QueryResponseMessage and the subsequent SubscriptionQueryUpdateMessage's and Axon Server gRPC SubscriptionQuery and SubscriptionQueryResponse.
SubscriptionQueryRequestTarget	A listener for Subscription Query requests and response, used by the AxonServerQueryBus to support the AxonServerQueryBus.subscriptionQuery(SubscriptionQueryMessage, SubscriptionQueryBackpressure, int) functionality.