Modifier and Type | Class and Description |
---|---|
class |
GrpcBackedResponseMessage<R>
Wrapper that allows clients to access a gRPC
QueryResponse as a QueryResponseMessage . |
Modifier and Type | Method and Description |
---|---|
<R> QueryResponseMessage<R> |
QuerySerializer.deserializeResponse(QueryResponse queryResponse,
ResponseType<R> expectedResponseType)
Convert a
QueryResponse into a 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) |
Modifier and Type | Method and Description |
---|---|
QueryResponse |
QuerySerializer.serializeResponse(QueryResponseMessage<?> queryResponse,
String requestMessageId)
Convert a
QueryResponseMessage into a QueryResponse . |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<QueryResponseMessage<I>> |
DeserializedResult.initialResult() |
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.
|
Modifier and Type | Method and Description |
---|---|
QueryResponseMessage<R> |
ConvertingResponseMessage.andMetaData(Map<String,?> additionalMetaData) |
QueryResponseMessage<R> |
ConvertingResponseMessage.withMetaData(Map<String,?> metaData) |
Constructor and Description |
---|
ConvertingResponseMessage(ResponseType<R> expectedResponseType,
QueryResponseMessage<?> responseMessage)
Initialize a response message, using
expectedResponseType to convert the payload from the responseMessage , if necessary. |
Modifier and Type | Class and Description |
---|---|
class |
GenericQueryResponseMessage<R>
QueryResponseMessage implementation that takes all properties as constructor parameters.
|
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 . |
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. |
Copyright © 2010–2020. All rights reserved.