Package | Description |
---|---|
org.axonframework.queryhandling |
Modifier and Type | Interface and Description |
---|---|
interface |
SubscriptionQueryUpdateMessage<U>
Message which holds incremental update of an subscription query.
|
Modifier and Type | Class and Description |
---|---|
class |
GenericQueryResponseMessage<R>
QueryResponseMessage implementation that takes all properties as constructor parameters.
|
class |
GenericSubscriptionQueryUpdateMessage<U>
Generic
SubscriptionQueryUpdateMessage which holds incremental update of an subscription query. |
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 . |
QueryResponseMessage<R> |
GenericQueryResponseMessage.andMetaData(Map<String,?> additionalMetaData) |
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(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 . |
QueryResponseMessage<R> |
GenericQueryResponseMessage.withMetaData(Map<String,?> 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–2018. All rights reserved.