com.liferay.portal.kernel.cluster
Class FutureClusterResponses
java.lang.Object
java.util.concurrent.FutureTask<T>
com.liferay.portal.kernel.concurrent.DefaultNoticeableFuture<ClusterNodeResponses>
com.liferay.portal.kernel.cluster.FutureClusterResponses
- All Implemented Interfaces:
- NoticeableFuture<ClusterNodeResponses>, Runnable, Future<ClusterNodeResponses>, RunnableFuture<ClusterNodeResponses>
public class FutureClusterResponses
- extends DefaultNoticeableFuture<ClusterNodeResponses>
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
FutureClusterResponses
public FutureClusterResponses(Set<String> clusterNodeIds)
addClusterNodeResponse
public boolean addClusterNodeResponse(ClusterNodeResponse clusterNodeResponse)
get
public ClusterNodeResponses get()
throws InterruptedException
- Specified by:
get in interface Future<ClusterNodeResponses>- Overrides:
get in class FutureTask<ClusterNodeResponses>
- Throws:
InterruptedException
get
public ClusterNodeResponses get(long timeout,
TimeUnit unit)
throws InterruptedException,
TimeoutException
- Specified by:
get in interface Future<ClusterNodeResponses>- Overrides:
get in class FutureTask<ClusterNodeResponses>
- Throws:
InterruptedException
TimeoutException
getPartialResults
public BlockingQueue<ClusterNodeResponse> getPartialResults()