Uses of Interface
org.axonframework.queryhandling.SubscriptionQueryResult
Packages that use SubscriptionQueryResult
Package
Description
-
Uses of SubscriptionQueryResult in org.axonframework.axonserver.connector.query
Methods in org.axonframework.axonserver.connector.query that return SubscriptionQueryResultModifier and TypeMethodDescription<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. -
Uses of SubscriptionQueryResult in org.axonframework.axonserver.connector.query.subscription
Classes in org.axonframework.axonserver.connector.query.subscription that implement SubscriptionQueryResultModifier and TypeClassDescriptionclassASubscriptionQueryResultthat emits initial response and update when subscription query response message is received.classDeserializedResult<I,U> Deprecated.in through use of the AxonServer java connectorclassDisposableResult<I,U> Deprecated.in through use of the AxonServer java connectorConstructors in org.axonframework.axonserver.connector.query.subscription with parameters of type SubscriptionQueryResultModifierConstructorDescriptionDeserializedResult(SubscriptionQueryResult<io.axoniq.axonserver.grpc.query.QueryResponse, io.axoniq.axonserver.grpc.query.QueryUpdate> delegate, SubscriptionMessageSerializer serializer) Deprecated.Instantiate aDeserializedResultwrapping thedelegatewhich will be serialized by the givenserializer.DisposableResult(SubscriptionQueryResult<I, U> delegate, Registration registration) Deprecated.Instantiate aDisposableResultwrapping thedelegate, opening up the capability toDisposableResult.cancel()it. -
Uses of SubscriptionQueryResult in org.axonframework.queryhandling
Classes in org.axonframework.queryhandling that implement SubscriptionQueryResultMethods in org.axonframework.queryhandling that return SubscriptionQueryResultModifier and TypeMethodDescription<Q,I, U> SubscriptionQueryResult <I, U> DefaultQueryGateway.subscriptionQuery(String queryName, Q query, ResponseType<I> initialResponseType, ResponseType<U> updateResponseType, int updateBufferSize) <Q,I, U> SubscriptionQueryResult <I, U> DefaultQueryGateway.subscriptionQuery(String queryName, Q query, ResponseType<I> initialResponseType, ResponseType<U> updateResponseType, SubscriptionQueryBackpressure backpressure, int updateBufferSize) Deprecated.default <Q,I, U> SubscriptionQueryResult <QueryResponseMessage<I>, SubscriptionQueryUpdateMessage<U>> QueryBus.subscriptionQuery(SubscriptionQueryMessage<Q, I, U> query) Dispatch the givenqueryto a single QueryHandler subscribed to the givenquery's queryName/initialResponseType/updateResponseType.default <Q,I, U> SubscriptionQueryResult <QueryResponseMessage<I>, SubscriptionQueryUpdateMessage<U>> QueryBus.subscriptionQuery(SubscriptionQueryMessage<Q, I, U> query, int updateBufferSize) Dispatch the givenqueryto a single QueryHandler subscribed to the givenquery's queryName/initialResponseType/updateResponseType.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)}default <Q,I, U> SubscriptionQueryResult <I, U> QueryGateway.subscriptionQuery(String queryName, Q query, Class<I> initialResponseType, Class<U> updateResponseType) Sends givenqueryover theQueryBusand 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 givenqueryover theQueryBusand 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 givenqueryover theQueryBusand 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, SubscriptionQueryBackpressure backpressure) Deprecated.in favour of using {QueryGateway.subscriptionQuery(String, Object, ResponseType, ResponseType)}.<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)}.default <Q,I, U> SubscriptionQueryResult <I, U> QueryGateway.subscriptionQuery(Q query, Class<I> initialResponseType, Class<U> updateResponseType) Sends givenqueryover theQueryBusand 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 givenqueryover theQueryBusand 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, int updateBufferSize) <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)
AxonServerQueryBus.subscriptionQuery(SubscriptionQueryMessage, int)}