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.messaging.responsetypes
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 that allows clients to access a gRPC QueryResponse as a QueryResponseMessage.

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

Modifier and Type	Method and Description
QueryResponseMessage<?>	QuerySerializer.deserializeResponse(io.axoniq.axonserver.grpc.query.QueryResponse queryResponse) Converts a QueryResponse into a QueryResponseMessage.
<R> QueryResponseMessage<R>	QuerySerializer.deserializeResponse(io.axoniq.axonserver.grpc.query.QueryResponse queryResponse, ResponseType<R> expectedResponseType) Convert a QueryResponse into a QueryResponseMessage.

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,R> org.reactivestreams.Publisher<QueryResponseMessage<R>>	AxonServerQueryBus.streamingQuery(StreamingQueryMessage<Q,R> query)
<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)}

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

Modifier and Type	Method and Description
io.axoniq.axonserver.grpc.query.QueryResponse	QuerySerializer.serializeResponse(QueryResponseMessage<?> queryResponse, String requestMessageId) Convert a QueryResponseMessage into a QueryResponse.

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

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

Modifier and Type	Method and Description
<I> QueryResponseMessage<I>	SubscriptionMessageSerializer.deserialize(io.axoniq.axonserver.grpc.query.QueryResponse queryResponse) Deserializes the given queryResponse into a QueryResponseMessage.

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() Deprecated.
reactor.core.publisher.Mono<QueryResponseMessage<I>>	AxonServerSubscriptionQueryResult.initialResult()

Uses of QueryResponseMessage in org.axonframework.messaging.responsetypes

Classes in org.axonframework.messaging.responsetypes that implement QueryResponseMessage

Modifier and Type	Class and Description
class	ConvertingResponseMessage<R> Implementation of a QueryResponseMessage that is aware of the requested response type and performs a just-in-time conversion to ensure the response is formatted as requested.

Methods in org.axonframework.messaging.responsetypes that return QueryResponseMessage

Modifier and Type	Method and Description
QueryResponseMessage<R>	ConvertingResponseMessage.andMetaData(Map<String,?> additionalMetaData)
QueryResponseMessage<R>	ConvertingResponseMessage.withMetaData(Map<String,?> metaData)

Constructors in org.axonframework.messaging.responsetypes with parameters of type QueryResponseMessage

Constructor and Description
ConvertingResponseMessage(ResponseType<R> expectedResponseType, QueryResponseMessage<?> responseMessage) Initialize a response message, using expectedResponseType to convert the payload from the responseMessage, if necessary.

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.
<Q,R> org.reactivestreams.Publisher<QueryResponseMessage<R>>	SimpleQueryBus.streamingQuery(StreamingQueryMessage<Q,R> query)
default <Q,R> org.reactivestreams.Publisher<QueryResponseMessage<R>>	QueryBus.streamingQuery(StreamingQueryMessage<Q,R> query) Builds a Publisher of responses to the given query.
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)}