Liferay 7.0-ce-b4

com.liferay.portal.kernel.cluster
Class FutureClusterResponses

java.lang.Object
  extended by java.util.concurrent.FutureTask<T>
      extended by com.liferay.portal.kernel.concurrent.DefaultNoticeableFuture<ClusterNodeResponses>
          extended by com.liferay.portal.kernel.cluster.FutureClusterResponses
All Implemented Interfaces:
NoticeableFuture<ClusterNodeResponses>, Runnable, Future<ClusterNodeResponses>, RunnableFuture<ClusterNodeResponses>

public class FutureClusterResponses
extends DefaultNoticeableFuture<ClusterNodeResponses>


Constructor Summary
FutureClusterResponses(Set<String> clusterNodeIds)
           
 
Method Summary
 boolean addClusterNodeResponse(ClusterNodeResponse clusterNodeResponse)
           
 ClusterNodeResponses get()
           
 ClusterNodeResponses get(long timeout, TimeUnit unit)
           
 BlockingQueue<ClusterNodeResponse> getPartialResults()
           
 
Methods inherited from class com.liferay.portal.kernel.concurrent.DefaultNoticeableFuture
addFutureListener, done, removeFutureListener, set, setException
 
Methods inherited from class java.util.concurrent.FutureTask
cancel, isCancelled, isDone, run, runAndReset
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface java.util.concurrent.Future
cancel, isCancelled, isDone
 

Constructor Detail

FutureClusterResponses

public FutureClusterResponses(Set<String> clusterNodeIds)
Method Detail

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()

Liferay 7.0-ce-b4