Uses of Interface
org.axonframework.messaging.queryhandling.QueryResponseMessage

Packages that use QueryResponseMessage

Package	Description
org.axonframework.axonserver.connector.query
org.axonframework.messaging.queryhandling
org.axonframework.messaging.queryhandling.annotation
org.axonframework.messaging.queryhandling.distributed
org.axonframework.messaging.queryhandling.gateway
org.axonframework.messaging.queryhandling.interception

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

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

Modifier and Type	Method	Description
protected abstract QueryResponseMessage	AbstractQueryResponseMessageStream.buildResponseMessage(T t)
protected QueryResponseMessage	QueryResponseMessageStream.buildResponseMessage(io.axoniq.axonserver.grpc.query.QueryResponse queryResponse)
protected QueryResponseMessage	QueryUpdateMessageStream.buildResponseMessage(io.axoniq.axonserver.grpc.query.QueryUpdate queryUpdate)
static QueryResponseMessage	QueryConverter.convertQueryResponse(io.axoniq.axonserver.grpc.query.QueryResponse queryResponse)	Converts a QueryResponse into a QueryResponseMessage.

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

Modifier and Type	Method	Description
Optional<MessageStream.Entry<QueryResponseMessage>>	AbstractQueryResponseMessageStream.next()
Optional<MessageStream.Entry<QueryResponseMessage>>	AbstractQueryResponseMessageStream.peek()
MessageStream<QueryResponseMessage>	AxonServerQueryBusConnector.query(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	AxonServerQueryBusConnector.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)

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

Modifier and Type	Method	Description
static io.axoniq.axonserver.grpc.query.QueryResponse	QueryConverter.convertQueryResponseMessage(String requestId, QueryResponseMessage queryResponseMessage)	Converts a QueryResponseMessage into a QueryResponse.

Uses of QueryResponseMessage in org.axonframework.messaging.queryhandling

Subinterfaces of QueryResponseMessage in org.axonframework.messaging.queryhandling

Modifier and Type	Interface	Description
interface	SubscriptionQueryUpdateMessage	A ResultMessage implementation that holds incremental update of a subscription query.

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

Modifier and Type	Class	Description
class	GenericQueryResponseMessage	Generic implementation of the QueryResponseMessage interface.
class	GenericSubscriptionQueryUpdateMessage	Generic implementation of the SubscriptionQueryUpdateMessage interface holding incremental update of a subscription query.

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

Modifier and Type	Method	Description
QueryResponseMessage	GenericQueryResponseMessage.andMetadata(Map<String,String> additionalMetadata)
QueryResponseMessage	QueryResponseMessage.andMetadata(Map<String,String> additionalMetadata)
QueryResponseMessage	GenericQueryResponseMessage.withConvertedPayload(Type type, Converter converter)
default QueryResponseMessage	QueryResponseMessage.withConvertedPayload(Class<?> type, Converter converter)
QueryResponseMessage	QueryResponseMessage.withConvertedPayload(Type type, Converter converter)
default QueryResponseMessage	QueryResponseMessage.withConvertedPayload(TypeReference<?> type, Converter converter)
QueryResponseMessage	GenericQueryResponseMessage.withMetadata(Map<String,String> metadata)
QueryResponseMessage	QueryResponseMessage.withMetadata(Map<String,String> metadata)

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

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	QueryHandler.handle(QueryMessage query, ProcessingContext context)	Handles the given query within the given context.
MessageStream<QueryResponseMessage>	SimpleQueryHandlingComponent.handle(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	QueryBus.query(QueryMessage query, ProcessingContext context)	Dispatch the given query to a QueryHandler subscribed to the given query's query name, returning a MessageStream of responses to the given query.
MessageStream<QueryResponseMessage>	SimpleQueryBus.query(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	QueryBus.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)	Dispatch the given query to a single QueryHandler subscribed to the given query's queryName/initialResponseType/updateResponseType.
MessageStream<QueryResponseMessage>	SimpleQueryBus.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)

Uses of QueryResponseMessage in org.axonframework.messaging.queryhandling.annotation

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

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	AnnotatedQueryHandlingComponent.handle(QueryMessage query, ProcessingContext context)

Uses of QueryResponseMessage in org.axonframework.messaging.queryhandling.distributed

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

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	DelegatingQueryBusConnector.query(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	DistributedQueryBus.query(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	PayloadConvertingQueryBusConnector.query(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	QueryBusConnector.Handler.query(QueryMessage query)	Handles the incoming query message.
MessageStream<QueryResponseMessage>	QueryBusConnector.query(QueryMessage query, ProcessingContext context)	Sends the given query to the remote QueryBus.
MessageStream<QueryResponseMessage>	DelegatingQueryBusConnector.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)
MessageStream<QueryResponseMessage>	DistributedQueryBus.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)
MessageStream<QueryResponseMessage>	PayloadConvertingQueryBusConnector.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)
MessageStream<QueryResponseMessage>	QueryBusConnector.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)	Sends the given query to the remote QueryBus.

Uses of QueryResponseMessage in org.axonframework.messaging.queryhandling.gateway

Method parameters in org.axonframework.messaging.queryhandling.gateway with type arguments of type QueryResponseMessage

Modifier and Type	Method	Description
<T> org.reactivestreams.Publisher<T>	DefaultQueryGateway.subscriptionQuery(Object query, Class<T> responseType, Function<QueryResponseMessage,T> mapper, ProcessingContext context, int updateBufferSize)
default <R> org.reactivestreams.Publisher<R>	QueryGateway.subscriptionQuery(Object query, Class<R> responseType, Function<QueryResponseMessage,R> mapper)	Sends given query over the QueryBus and returns a Publisher supplying the initial update followed by the update.
default <R> org.reactivestreams.Publisher<R>	QueryGateway.subscriptionQuery(Object query, Class<R> responseType, Function<QueryResponseMessage,R> mapper, int updateBufferSize)	Sends given query over the QueryBus and returns a Publisher supplying the initial update followed by the update.
default <R> org.reactivestreams.Publisher<R>	QueryGateway.subscriptionQuery(Object query, Class<R> responseType, Function<QueryResponseMessage,R> mapper, ProcessingContext context)	Sends given query over the QueryBus and returns a Publisher supplying the initial update followed by the update.
<R> org.reactivestreams.Publisher<R>	QueryGateway.subscriptionQuery(Object query, Class<R> responseType, Function<QueryResponseMessage,R> mapper, ProcessingContext context, int updateBufferSize)	Sends given query over the QueryBus and returns a Publisher supplying the initial update followed by the update.

Uses of QueryResponseMessage in org.axonframework.messaging.queryhandling.interception

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

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	InterceptingQueryBus.query(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	InterceptingQueryBus.subscriptionQuery(QueryMessage query, ProcessingContext context, int updateBufferSize)