Modifier and Type | Method and Description |
---|---|
ResponseType<R> |
GrpcBackedQueryMessage.getResponseType() |
Constructor and Description |
---|
GrpcBackedQueryMessage(QueryRequest query,
Serializer messageSerializer,
LazyDeserializingObject<Q> serializedPayload,
LazyDeserializingObject<ResponseType<R>> serializedResponseType,
Supplier<MetaData> metadata) |
Modifier and Type | Method and Description |
---|---|
ResponseType<I> |
GrpcBackedSubscriptionQueryMessage.getResponseType() |
ResponseType<U> |
GrpcBackedSubscriptionQueryMessage.getUpdateResponseType() |
Modifier and Type | Method and Description |
---|---|
<C,R> CommandGatewayFactory |
CommandGatewayFactory.registerCommandCallback(CommandCallback<C,R> callback,
ResponseType<R> responseType)
Registers the
callback , which is invoked for each sent command, unless Axon is able to detect that
the result of the command does not match the type accepted by the callback. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractResponseType<R>
Abstract implementation of the
ResponseType which contains
match functions for the majority of the Type options available. |
class |
InstanceResponseType<R>
A
ResponseType implementation that will match with query
handlers which return a single instance of the expected response type. |
class |
MultipleInstancesResponseType<R>
A
ResponseType implementation that will match with query
handlers which return a multiple instances of the expected response type. |
Modifier and Type | Method and Description |
---|---|
static <R> ResponseType<R> |
ResponseTypes.instanceOf(Class<R> type)
Specify the desire to retrieve a single instance of type
R when performing a query. |
static <R> ResponseType<List<R>> |
ResponseTypes.multipleInstancesOf(Class<R> type)
Specify the desire to retrieve a collection of instances of type
R when performing a query. |
Modifier and Type | Method and Description |
---|---|
ResponseType<R> |
QueryMessage.getResponseType()
The type of response expected by the sender of the query
|
ResponseType<R> |
GenericQueryMessage.getResponseType() |
ResponseType<U> |
SubscriptionQueryMessage.getUpdateResponseType()
Returns the type of incremental responses.
|
ResponseType<U> |
GenericSubscriptionQueryMessage.getUpdateResponseType() |
Modifier and Type | Method and Description |
---|---|
default <R,Q> CompletableFuture<R> |
QueryGateway.query(Q query,
ResponseType<R> responseType)
Sends given
query over the QueryBus , expecting a response in the
form of responseType from a single source. |
<R,Q> CompletableFuture<R> |
QueryGateway.query(String queryName,
Q query,
ResponseType<R> responseType)
Sends given
query over the QueryBus , expecting a response in the
form of responseType from a single source. |
<R,Q> CompletableFuture<R> |
DefaultQueryGateway.query(String queryName,
Q query,
ResponseType<R> responseType) |
default <R,Q> Stream<R> |
QueryGateway.scatterGather(Q query,
ResponseType<R> responseType,
long timeout,
TimeUnit timeUnit)
Sends given
query over the QueryBus , expecting a response in the
form of responseType from several sources. |
<R,Q> Stream<R> |
QueryGateway.scatterGather(String queryName,
Q query,
ResponseType<R> responseType,
long timeout,
TimeUnit timeUnit)
Sends given
query over the QueryBus , expecting a response in the
form of responseType from several sources. |
<R,Q> Stream<R> |
DefaultQueryGateway.scatterGather(String queryName,
Q query,
ResponseType<R> responseType,
long timeout,
TimeUnit timeUnit) |
default <Q,I,U> SubscriptionQueryResult<I,U> |
QueryGateway.subscriptionQuery(Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType)
Sends given
query over the QueryBus and returns result containing initial response and
incremental updates (received at the moment the query is sent, until it is cancelled by the caller or closed by
the emitting side). |
default <Q,I,U> SubscriptionQueryResult<I,U> |
QueryGateway.subscriptionQuery(Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType)
Sends given
query over the QueryBus and returns result containing initial response and
incremental updates (received at the moment the query is sent, until it is cancelled by the caller or closed by
the emitting side). |
default <Q,I,U> SubscriptionQueryResult<I,U> |
QueryGateway.subscriptionQuery(String queryName,
Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType,
SubscriptionQueryBackpressure backpressure)
Sends given
query over the QueryBus and returns result containing initial response and
incremental updates (received at the moment the query is sent, until it is cancelled by the caller or closed by
the emitting side). |
default <Q,I,U> SubscriptionQueryResult<I,U> |
QueryGateway.subscriptionQuery(String queryName,
Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType,
SubscriptionQueryBackpressure backpressure)
Sends given
query over the QueryBus and returns result containing initial response and
incremental updates (received at the moment the query is sent, until it is cancelled by the caller or closed by
the emitting side). |
<Q,I,U> SubscriptionQueryResult<I,U> |
QueryGateway.subscriptionQuery(String queryName,
Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize)
Sends given
query over the QueryBus and returns result containing initial response and
incremental updates (received at the moment the query is sent, until it is cancelled by the caller or closed by
the emitting side). |
<Q,I,U> SubscriptionQueryResult<I,U> |
QueryGateway.subscriptionQuery(String queryName,
Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize)
Sends given
query over the QueryBus and returns result containing initial response and
incremental updates (received at the moment the query is sent, until it is cancelled by the caller or closed by
the emitting side). |
<Q,I,U> SubscriptionQueryResult<I,U> |
DefaultQueryGateway.subscriptionQuery(String queryName,
Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize) |
<Q,I,U> SubscriptionQueryResult<I,U> |
DefaultQueryGateway.subscriptionQuery(String queryName,
Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize) |
Constructor and Description |
---|
GenericQueryMessage(Message<T> delegate,
String queryName,
ResponseType<R> responseType)
Initialize the Query Message, using given
delegate as the carrier of payload and metadata and given
queryName and expecting the given responseType . |
GenericQueryMessage(T payload,
ResponseType<R> responseType)
Initializes the message with the given
payload and expected responseType . |
GenericQueryMessage(T payload,
String queryName,
ResponseType<R> responseType)
Initializes the message with the given
payload , queryName and expected responseType . |
GenericSubscriptionQueryMessage(Message<Q> delegate,
String queryName,
ResponseType<I> responseType,
ResponseType<U> updateResponseType)
Initializes the message, using given
delegate as the carrier of payload and metadata and given queryName , expected responseType and expected updateResponseType . |
GenericSubscriptionQueryMessage(Message<Q> delegate,
String queryName,
ResponseType<I> responseType,
ResponseType<U> updateResponseType)
Initializes the message, using given
delegate as the carrier of payload and metadata and given queryName , expected responseType and expected updateResponseType . |
GenericSubscriptionQueryMessage(Q payload,
ResponseType<I> responseType,
ResponseType<U> updateResponseType)
Initializes the message with the given
payload , expected responseType and expected updateResponseType . |
GenericSubscriptionQueryMessage(Q payload,
ResponseType<I> responseType,
ResponseType<U> updateResponseType)
Initializes the message with the given
payload , expected responseType and expected updateResponseType . |
GenericSubscriptionQueryMessage(Q payload,
String queryName,
ResponseType<I> responseType,
ResponseType<U> updateResponseType)
Initializes the message with the given
payload , queryName , expected responseType and
expected updateResponseType . |
GenericSubscriptionQueryMessage(Q payload,
String queryName,
ResponseType<I> responseType,
ResponseType<U> updateResponseType)
Initializes the message with the given
payload , queryName , expected responseType and
expected updateResponseType . |
Copyright © 2010–2018. All rights reserved.