Uses of Interface
org.axonframework.queryhandling.QueryResponseMessage

Packages that use QueryResponseMessage

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

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

Classes in org.axonframework.axonserver.connector.query that implement QueryResponseMessage

Modifier and Type	Class and Description
class	GrpcBackedResponseMessage<R> Wrapper around GRPC QueryRequest to implement the QueryMessage interface

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

Modifier and Type	Method and Description
QueryResponseMessage<R>	GrpcBackedResponseMessage.andMetaData(Map<String,?> var1)
<R> QueryResponseMessage<R>	QuerySerializer.deserializeResponse(QueryResponse commandResponse)

Methods in org.axonframework.axonserver.connector.query that return types with arguments of type QueryResponseMessage

Modifier and Type	Method and Description
<Q,R> CompletableFuture<QueryResponseMessage<R>>	AxonServerQueryBus.query(QueryMessage<Q,R> queryMessage)
<Q,R> Stream<QueryResponseMessage<R>>	AxonServerQueryBus.scatterGather(QueryMessage<Q,R> queryMessage, long timeout, TimeUnit timeUnit)
<Q,I,U> SubscriptionQueryResult<QueryResponseMessage<I>,SubscriptionQueryUpdateMessage<U>>	AxonServerQueryBus.subscriptionQuery(SubscriptionQueryMessage<Q,I,U> query, SubscriptionQueryBackpressure backPressure, int updateBufferSize)

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

Modifier and Type	Method and Description
QueryResponse	QuerySerializer.serializeResponse(QueryResponseMessage<?> response, String requestMessageId)

Uses of QueryResponseMessage in org.axonframework.axonserver.connector.query.subscription

Methods in org.axonframework.axonserver.connector.query.subscription that return types with arguments of type QueryResponseMessage

Modifier and Type	Method and Description
reactor.core.publisher.Mono<QueryResponseMessage<I>>	DeserializedResult.initialResult()

Uses of QueryResponseMessage in org.axonframework.queryhandling

Classes in org.axonframework.queryhandling that implement QueryResponseMessage

Modifier and Type	Class and Description
class	GenericQueryResponseMessage<R> QueryResponseMessage implementation that takes all properties as constructor parameters.

Methods in org.axonframework.queryhandling that return QueryResponseMessage

Modifier and Type	Method and Description
QueryResponseMessage<T>	QueryResponseMessage.andMetaData(Map<String,?> additionalMetaData) Returns a copy of this QueryResponseMessage with its MetaData merged with given metaData.
static <R> QueryResponseMessage<R>	GenericQueryResponseMessage.asNullableResponseMessage(Class<R> declaredType, Object result) Creates a QueryResponseMessage for the given result with a declaredType as the result type.
static <R> QueryResponseMessage<R>	GenericQueryResponseMessage.asResponseMessage(Class<R> declaredType, Throwable exception) Creates a Query Response Message with given declaredType and exception.
static <R> QueryResponseMessage<R>	GenericQueryResponseMessage.asResponseMessage(Object result) Creates a QueryResponseMessage for the given result.
QueryResponseMessage<T>	QueryResponseMessage.withMetaData(Map<String,?> metaData) Returns a copy of this QueryResponseMessage with the given metaData.

Methods in org.axonframework.queryhandling that return types with arguments of type QueryResponseMessage

Modifier and Type	Method and Description
<Q,R> CompletableFuture<QueryResponseMessage<R>>	SimpleQueryBus.query(QueryMessage<Q,R> query)
<Q,R> CompletableFuture<QueryResponseMessage<R>>	QueryBus.query(QueryMessage<Q,R> query) Dispatch the given query to a single QueryHandler subscribed to the given query's queryName and responseType.
<Q,R> Stream<QueryResponseMessage<R>>	SimpleQueryBus.scatterGather(QueryMessage<Q,R> query, long timeout, TimeUnit unit)
<Q,R> Stream<QueryResponseMessage<R>>	QueryBus.scatterGather(QueryMessage<Q,R> query, long timeout, TimeUnit unit) Dispatch the given query to all QueryHandlers subscribed to the given query's queryName/responseType.
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, 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.