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(List<Address> addresses)
addClusterNodeResponse
public void addClusterNodeResponse(ClusterNodeResponse clusterNodeResponse)
expectsReply
public boolean expectsReply(Address address)
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()