public interface QueryGateway
| Modifier and Type | Method and Description |
|---|---|
default <R,Q> CompletableFuture<R> |
send(Q query,
Class<R> responseType)
sends given query to the query bus and expects a result of type resultClass.
|
default <R,Q> Stream<R> |
send(Q query,
Class<R> responseType,
long timeout,
TimeUnit timeUnit)
sends given query to the query bus and expects a stream of results with type responseType.
|
<R,Q> CompletableFuture<R> |
send(Q query,
String queryName,
Class<R> responseType)
sends given query to the query bus and expects a result with name resultName.
|
<R,Q> Stream<R> |
send(Q query,
String queryName,
Class<R> resultClass,
long timeout,
TimeUnit timeUnit)
sends given query to the query bus and expects a stream of results with name resultName.
|
default <R,Q> CompletableFuture<R> send(Q query, Class<R> responseType)
R - The type of result expected from query executionQ - The query classquery - the queryresponseType - the expected result typeNullPointerException - when query is null<R,Q> CompletableFuture<R> send(Q query, String queryName, Class<R> responseType)
R - The type of result expected from query executionQ - The query classquery - the queryqueryName - the name of the queryresponseType - the expected response type<R,Q> Stream<R> send(Q query, String queryName, Class<R> resultClass, long timeout, TimeUnit timeUnit)
R - The type of result expected from query executionQ - The query classquery - the queryqueryName - the name of the queryresultClass - type type of resulttimeout - timeout for the requesttimeUnit - unit for the timeoutdefault <R,Q> Stream<R> send(Q query, Class<R> responseType, long timeout, TimeUnit timeUnit)
R - The type of result expected from query executionQ - The query classquery - the queryresponseType - the expected result typetimeout - timeout for the requesttimeUnit - unit for the timeoutNullPointerException - when query is nullCopyright © 2010–2017. All rights reserved.