Uses of Class
org.axonframework.queryhandling.SubscriptionQueryBackpressure

Packages that use SubscriptionQueryBackpressure

Package	Description
org.axonframework.queryhandling

Uses of SubscriptionQueryBackpressure in org.axonframework.queryhandling

Methods in org.axonframework.queryhandling that return SubscriptionQueryBackpressure

Modifier and Type	Method and Description
static SubscriptionQueryBackpressure	SubscriptionQueryBackpressure.defaultBackpressure() Creates default backpressure - FluxSink.OverflowStrategy#ERROR.

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

Modifier and Type	Method and Description
default <Q,I,U> SubscriptionQueryResult<I,U>	QueryGateway.subscriptionQuery(String queryName, Q query, ResponseType<I> initialResponseType, ResponseType<U> updateResponseType, SubscriptionQueryBackpressure backpressure) 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, SubscriptionQueryBackpressure backpressure, 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, SubscriptionQueryBackpressure backpressure, int updateBufferSize)
<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.