Uses of Class
org.axonframework.queryhandling.SubscriptionQueryBackpressure

Packages that use SubscriptionQueryBackpressure

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

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

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

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

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

Constructor and Description

AxonServerSubscriptionQueryResult(SubscriptionQuery subscriptionQuery, Function<io.grpc.stub.StreamObserver<SubscriptionQueryResponse>,io.grpc.stub.StreamObserver<SubscriptionQueryRequest>> openStreamFn, AxonServerConfiguration configuration, SubscriptionQueryBackpressure backPressure, int bufferSize, Runnable onDispose) Instantiate a AxonServerSubscriptionQueryResult which will emit its initial response and the updates of the subscription query.

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, using Project Reactor's FluxSink.OverflowStrategy ERROR strategy.

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

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