public class FutureClusterResponses extends DefaultNoticeableFuture<ClusterNodeResponses>
| Constructor and Description |
|---|
FutureClusterResponses(java.util.Set<java.lang.String> clusterNodeIds) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
addClusterNodeResponse(ClusterNodeResponse clusterNodeResponse) |
ClusterNodeResponses |
get() |
ClusterNodeResponses |
get(long timeout,
java.util.concurrent.TimeUnit unit) |
java.util.concurrent.BlockingQueue<ClusterNodeResponse> |
getPartialResults() |
addFutureListener, done, removeFutureListener, set, setExceptioncancel, isCancelled, isDone, run, runAndResetpublic FutureClusterResponses(java.util.Set<java.lang.String> clusterNodeIds)
public boolean addClusterNodeResponse(ClusterNodeResponse clusterNodeResponse)
public ClusterNodeResponses get() throws java.lang.InterruptedException
get in interface java.util.concurrent.Future<ClusterNodeResponses>get in class java.util.concurrent.FutureTask<ClusterNodeResponses>java.lang.InterruptedExceptionpublic ClusterNodeResponses get(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException, java.util.concurrent.TimeoutException
get in interface java.util.concurrent.Future<ClusterNodeResponses>get in class java.util.concurrent.FutureTask<ClusterNodeResponses>java.lang.InterruptedExceptionjava.util.concurrent.TimeoutExceptionpublic java.util.concurrent.BlockingQueue<ClusterNodeResponse> getPartialResults()