Uses of Interface
org.axonframework.queryhandling.SubscriptionQueryResult

Packages that use SubscriptionQueryResult

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

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

Methods in org.axonframework.axonserver.connector.query that return SubscriptionQueryResult

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

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

Modifier and Type	Class and Description
class	AxonServerSubscriptionQueryResult<I,U> A SubscriptionQueryResult that emits initial response and update when subscription query response message is received.
class	DeserializedResult<I,U> Deprecated. in through use of the AxonServer java connector
class	DisposableResult<I,U> Deprecated. in through use of the AxonServer java connector

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

Constructor and Description
DeserializedResult(SubscriptionQueryResult<io.axoniq.axonserver.grpc.query.QueryResponse,io.axoniq.axonserver.grpc.query.QueryUpdate> delegate, SubscriptionMessageSerializer serializer) Deprecated. Instantiate a DeserializedResult wrapping the delegate which will be serialized by the given serializer.
DisposableResult(SubscriptionQueryResult<I,U> delegate, Registration registration) Deprecated. Instantiate a DisposableResult wrapping the delegate, opening up the capability to DisposableResult.cancel() it.

Uses of SubscriptionQueryResult in org.axonframework.queryhandling

Classes in org.axonframework.queryhandling that implement SubscriptionQueryResult

Modifier and Type	Class and Description
class	DefaultSubscriptionQueryResult<I,U> Default implementation of SubscriptionQueryResult.

Methods in org.axonframework.queryhandling that return SubscriptionQueryResult

Modifier and Type	Method and Description
default <Q,I,U> SubscriptionQueryResult<I,U>	QueryGateway.subscriptionQuery(Q query, Class<I> initialResponseType, Class<U> updateResponseType) Sends given query over the QueryBus and returns result containing initial response and incremental updates (received at the moment the query is sent, until it is cancelled by the caller or closed by the emitting side).
default <Q,I,U> SubscriptionQueryResult<I,U>	QueryGateway.subscriptionQuery(Q query, ResponseType<I> initialResponseType, ResponseType<U> updateResponseType) Sends given query over the QueryBus and returns result containing initial response and incremental updates (received at the moment the query is sent, until it is cancelled by the caller or closed by the emitting side).
default <Q,I,U> SubscriptionQueryResult<I,U>	QueryGateway.subscriptionQuery(String queryName, Q query, Class<I> initialResponseType, Class<U> updateResponseType) Sends given query over the QueryBus and returns result containing initial response and incremental updates (received at the moment the query is sent, until it is cancelled by the caller or closed by the emitting side).
default <Q,I,U> SubscriptionQueryResult<I,U>	QueryGateway.subscriptionQuery(String queryName, Q query, ResponseType<I> initialResponseType, ResponseType<U> updateResponseType) Sends given query over the QueryBus and returns result containing initial response and incremental updates (received at the moment the query is sent, until it is cancelled by the caller or closed by the emitting side).
<Q,I,U> SubscriptionQueryResult<I,U>	QueryGateway.subscriptionQuery(String queryName, Q query, ResponseType<I> initialResponseType, ResponseType<U> updateResponseType, int updateBufferSize) Sends given query over the QueryBus and returns result containing initial response and incremental updates (received at the moment the query is sent, until it is cancelled by the caller or closed by the emitting side).
<Q,I,U> SubscriptionQueryResult<I,U>	DefaultQueryGateway.subscriptionQuery(String queryName, Q query, ResponseType<I> initialResponseType, ResponseType<U> updateResponseType, int updateBufferSize)
default <Q,I,U> SubscriptionQueryResult<I,U>	QueryGateway.subscriptionQuery(String queryName, Q query, ResponseType<I> initialResponseType, ResponseType<U> updateResponseType, SubscriptionQueryBackpressure backpressure) Deprecated. in favour of using {QueryGateway.subscriptionQuery(String, Object, ResponseType, ResponseType)}. To set a backpressure strategy, use one of the onBackpressure.. operators on the updates flux directly. Example: result.updates().onBackpressureBuffer(100)
<Q,I,U> SubscriptionQueryResult<I,U>	QueryGateway.subscriptionQuery(String queryName, Q query, ResponseType<I> initialResponseType, ResponseType<U> updateResponseType, SubscriptionQueryBackpressure backpressure, int updateBufferSize) Deprecated. in favour of using {QueryGateway.subscriptionQuery(String, Object, ResponseType, ResponseType, int)}. To set a backpressure strategy, use one of the onBackpressure.. operators on the updates flux directly. Example: result.updates().onBackpressureBuffer(100)
<Q,I,U> SubscriptionQueryResult<I,U>	DefaultQueryGateway.subscriptionQuery(String queryName, Q query, ResponseType<I> initialResponseType, ResponseType<U> updateResponseType, SubscriptionQueryBackpressure backpressure, int updateBufferSize) Deprecated. in favour of the {DefaultQueryGateway.subscriptionQuery(String, Object, ResponseType, ResponseType, 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)}