public class FutureClusterResponses extends DefaultNoticeableFuture<ClusterNodeResponses>
| Constructor and Description |
|---|
FutureClusterResponses(Set<String> clusterNodeIds) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
addClusterNodeResponse(ClusterNodeResponse clusterNodeResponse) |
ClusterNodeResponses |
get() |
ClusterNodeResponses |
get(long timeout,
TimeUnit unit) |
BlockingQueue<ClusterNodeResponse> |
getPartialResults() |
addFutureListener, done, removeFutureListener, set, setExceptionpublic boolean addClusterNodeResponse(ClusterNodeResponse clusterNodeResponse)
public ClusterNodeResponses get() throws InterruptedException
get in interface Future<ClusterNodeResponses>get in class FutureTask<ClusterNodeResponses>InterruptedExceptionpublic ClusterNodeResponses get(long timeout, TimeUnit unit) throws InterruptedException, TimeoutException
get in interface Future<ClusterNodeResponses>get in class FutureTask<ClusterNodeResponses>InterruptedExceptionTimeoutExceptionpublic BlockingQueue<ClusterNodeResponse> getPartialResults()