Package | Description |
---|---|
org.axonframework.queryhandling |
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 . |
QueryResponseMessage<R> |
GenericQueryResponseMessage.andMetaData(Map<String,?> additionalMetaData) |
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/responseName. |
Copyright © 2010–2018. All rights reserved.