Modifier and Type | Method and Description |
---|---|
ResponseType<R> |
GrpcBackedQueryMessage.getResponseType() |
Modifier and Type | Method and Description |
---|---|
<R> QueryResponseMessage<R> |
QuerySerializer.deserializeResponse(io.axoniq.axonserver.grpc.query.QueryResponse queryResponse,
ResponseType<R> expectedResponseType)
Convert a
QueryResponse into a QueryResponseMessage . |
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. |
class |
OptionalResponseType<R>
A
ResponseType implementation that will match with query handlers which return a single instance of the
expected response type, but returns that as an Optional containing the result. |
class |
PublisherResponseType<R>
A
ResponseType implementation that will match with query
handlers that return a Publisher stream of the expected response type. |
Modifier and Type | Method and Description |
---|---|
default ResponseType<?> |
ResponseType.forSerialization()
Returns the
ResponseType instance that should be used when serializing responses. |
ResponseType<?> |
PublisherResponseType.forSerialization() |
ResponseType<?> |
OptionalResponseType.forSerialization() |
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. |
static <R> ResponseType<Optional<R>> |
ResponseTypes.optionalInstanceOf(Class<R> type)
Specify the desire to retrieve an
Optional<R> when performing a query. |
static <R> ResponseType<org.reactivestreams.Publisher<R>> |
ResponseTypes.publisherOf(Class<R> type)
Specify the desire to retrieve a Publisher (reactive stream) of instances of type
R when performing a
query. |
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 | Method and Description |
---|---|
ResponseType<org.reactivestreams.Publisher<R>> |
StreamingQueryMessage.getResponseType() |
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 |
---|---|
boolean |
QuerySubscription.canHandle(ResponseType<?> queryResponseType)
Check if this
QuerySubscription can handle the given queryResponseType , by calling the matches(Type) function on it and providing the set responseType of this subscription. |
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)
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)
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,
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,
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,
int updateBufferSize) |
<Q,I,U> SubscriptionQueryResult<I,U> |
DefaultQueryGateway.subscriptionQuery(String queryName,
Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType,
int updateBufferSize) |
default <Q,I,U> SubscriptionQueryResult<I,U> |
QueryGateway.subscriptionQuery(String queryName,
Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType,
SubscriptionQueryBackpressure backpressure)
Deprecated.
in favour of using {
QueryGateway.subscriptionQuery(String, Object, ResponseType, ResponseType) }.
To set a backpressure strategy, use one of the onBackpressure.. operators on the updates flux directly.
Example: result.updates().onBackpressureBuffer(100) |
default <Q,I,U> SubscriptionQueryResult<I,U> |
QueryGateway.subscriptionQuery(String queryName,
Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType,
SubscriptionQueryBackpressure backpressure)
Deprecated.
in favour of using {
QueryGateway.subscriptionQuery(String, Object, ResponseType, ResponseType) }.
To set a backpressure strategy, use one of the onBackpressure.. operators on the updates flux directly.
Example: result.updates().onBackpressureBuffer(100) |
<Q,I,U> SubscriptionQueryResult<I,U> |
QueryGateway.subscriptionQuery(String queryName,
Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize)
Deprecated.
in favour of using {
QueryGateway.subscriptionQuery(String, Object, ResponseType, ResponseType, int) }.
To set a backpressure strategy, use one of the onBackpressure.. operators on the updates flux directly.
Example: result.updates().onBackpressureBuffer(100) |
<Q,I,U> SubscriptionQueryResult<I,U> |
QueryGateway.subscriptionQuery(String queryName,
Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize)
Deprecated.
in favour of using {
QueryGateway.subscriptionQuery(String, Object, ResponseType, ResponseType, int) }.
To set a backpressure strategy, use one of the onBackpressure.. operators on the updates flux directly.
Example: result.updates().onBackpressureBuffer(100) |
<Q,I,U> SubscriptionQueryResult<I,U> |
DefaultQueryGateway.subscriptionQuery(String queryName,
Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize)
Deprecated.
|
<Q,I,U> SubscriptionQueryResult<I,U> |
DefaultQueryGateway.subscriptionQuery(String queryName,
Q query,
ResponseType<I> initialResponseType,
ResponseType<U> updateResponseType,
SubscriptionQueryBackpressure backpressure,
int updateBufferSize)
Deprecated.
|
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 . |
GenericStreamingQueryMessage(Message<Q> delegate,
String queryName,
ResponseType<org.reactivestreams.Publisher<R>> responseType)
Initialize the Query Message, using given
delegate as the carrier of payload and metadata and given
queryName and expecting the given responseType . |
GenericStreamingQueryMessage(Q payload,
ResponseType<org.reactivestreams.Publisher<R>> responseType)
Initializes the message with the given
payload and expected responseType . |
GenericStreamingQueryMessage(Q payload,
String queryName,
ResponseType<org.reactivestreams.Publisher<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–2024. All rights reserved.