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

Packages that use QueryResponseMessage

Package	Description
io.axoniq.framework.axonserver.connector.query	Part of the Axon Server Connector module.
io.axoniq.framework.messaging.multitenancy.axonserver.queryhandling	Part of the Axoniq Framework multi-tenancy module.
io.axoniq.framework.messaging.multitenancy.queryhandling	Package containing multitenancy support for query components.
io.axoniq.framework.messaging.queryhandling.distributed	Part of the Axon Messaging module.
io.axoniq.framework.messaging.queryhandling.distributed.tracing	Internal delegating tracing decorator for the distributed QueryBusConnector.
io.axoniq.framework.springcloud.query	The query side of the Spring Cloud connector: the connector distributing queries and subscription queries, and the HTTP transport carrying them between members of the cluster.
org.axonframework.messaging.queryhandling	Package for query handling components in Axon Framework.
org.axonframework.messaging.queryhandling.annotation	Part of the Axon Messaging module.
org.axonframework.messaging.queryhandling.gateway	Part of the Axon Messaging module.
org.axonframework.messaging.queryhandling.interception	Part of the Axon Messaging module.
org.axonframework.messaging.queryhandling.tracing	Tracing decorators for query handling components.

Uses of QueryResponseMessage in io.axoniq.framework.axonserver.connector.query

Methods in io.axoniq.framework.axonserver.connector.query that return QueryResponseMessage

Modifier and Type	Method	Description
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, @Nullable Converter converter)	Converts a QueryResponse into a QueryResponseMessage.

Methods in io.axoniq.framework.axonserver.connector.query that return types with arguments of type QueryResponseMessage

Modifier and Type	Method	Description
protected AbstractMessageStream.FetchResult<MessageStream.Entry<QueryResponseMessage>>	AbstractQueryResponseMessageStream.fetchNext()
MessageStream<QueryResponseMessage>	AxonServerQueryBusConnector.query(QueryMessage query, @Nullable ProcessingContext context)
MessageStream<QueryResponseMessage>	AxonServerQueryBusConnector.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)

Methods in io.axoniq.framework.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 io.axoniq.framework.messaging.multitenancy.axonserver.queryhandling

Methods in io.axoniq.framework.messaging.multitenancy.axonserver.queryhandling that return types with arguments of type QueryResponseMessage

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	MultiTenantAxonServerQueryBusConnector.query(QueryMessage query, @Nullable ProcessingContext context)	Resolves the connector for the current tenant and subsequently dispatches the given query to it.
MessageStream<QueryResponseMessage>	MultiTenantAxonServerQueryBusConnector.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)	Resolves the connector for the current tenant and subsequently dispatches the given subscription query to it.

Uses of QueryResponseMessage in io.axoniq.framework.messaging.multitenancy.queryhandling

Methods in io.axoniq.framework.messaging.multitenancy.queryhandling that return types with arguments of type QueryResponseMessage

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	TenantAwareQueryBus.query(QueryMessage query, @Nullable ProcessingContext context)	Dispatches the given query for the tenant resolved from it.
MessageStream<QueryResponseMessage>	TenantAwareQueryBus.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)

Uses of QueryResponseMessage in io.axoniq.framework.messaging.queryhandling.distributed

Methods in io.axoniq.framework.messaging.queryhandling.distributed that return types with arguments of type QueryResponseMessage

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

Uses of QueryResponseMessage in io.axoniq.framework.messaging.queryhandling.distributed.tracing

Methods in io.axoniq.framework.messaging.queryhandling.distributed.tracing that return types with arguments of type QueryResponseMessage

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

Uses of QueryResponseMessage in io.axoniq.framework.springcloud.query

Methods in io.axoniq.framework.springcloud.query that return types with arguments of type QueryResponseMessage

Modifier and Type	Method	Description
MessageStream<QueryResponseMessage>	HttpRemoteQueryDispatcher.dispatch(Member member, QueryMessage query)
MessageStream<QueryResponseMessage>	RemoteQueryDispatcher.dispatch(Member member, QueryMessage query)	Sends the given query to the given member, reporting the responses it streams back.
MessageStream<QueryResponseMessage>	HttpRemoteQueryDispatcher.openSubscriptionQueryUpdateStream(Member member, QueryMessage query, int updateBufferSize, RemoteQueryDispatcher.SubscriptionListener listener)
MessageStream<QueryResponseMessage>	RemoteQueryDispatcher.openSubscriptionQueryUpdateStream(Member member, QueryMessage query, int updateBufferSize, RemoteQueryDispatcher.SubscriptionListener listener)	Opens the stream of updates the given query produces on the given member.
MessageStream<QueryResponseMessage>	SpringCloudQueryBusConnector.query(QueryMessage query, @Nullable ProcessingContext context)
MessageStream<QueryResponseMessage>	SpringCloudQueryBusConnector.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)

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>	QueryHandlingExceptionHandler.handle(QueryMessage query, ProcessingContext context, Throwable error)	Called when a query handler throws an exception.
MessageStream<QueryResponseMessage>	SimpleQueryHandlingComponent.handle(QueryMessage query, ProcessingContext context)
MessageStream<QueryResponseMessage>	QueryBus.query(QueryMessage query, @Nullable 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, @Nullable ProcessingContext context)
MessageStream<QueryResponseMessage>	QueryBus.subscriptionQuery(QueryMessage query, @Nullable 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, @Nullable 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.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, @Nullable 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, @Nullable 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, @Nullable ProcessingContext context, int updateBufferSize)	Sends given query over the QueryBus and returns a Publisher supplying the initial update followed by the update.
<R> org.reactivestreams.Publisher<R>	ShutdownTrackingQueryGateway.subscriptionQuery(Object query, Class<R> responseType, Function<QueryResponseMessage,R> mapper, @Nullable ProcessingContext context, int updateBufferSize)

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>	InterceptingQueryHandlingComponent.handle(QueryMessage query, ProcessingContext processingContext)
MessageStream<QueryResponseMessage>	InterceptingQueryBus.query(QueryMessage query, @Nullable ProcessingContext context)
MessageStream<QueryResponseMessage>	InterceptingQueryBus.subscriptionQuery(QueryMessage query, @Nullable ProcessingContext context, int updateBufferSize)

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

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

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