Liferay 6.2-ce-ga5

com.liferay.portal.kernel.cluster
Class FutureClusterResponses

java.lang.Object
  extended by com.liferay.portal.kernel.cluster.FutureClusterResponses
All Implemented Interfaces:
Future<ClusterNodeResponses>

public class FutureClusterResponses
extends Object
implements Future<ClusterNodeResponses>


Constructor Summary
FutureClusterResponses(List<Address> addresses)
           
 
Method Summary
 void addClusterNodeResponse(ClusterNodeResponse clusterNodeResponse)
           
 void addExpectedReplyAddress(Address address)
           
 boolean cancel(boolean mayInterruptIfRunning)
           
 boolean expectsReply(Address address)
           
 ClusterNodeResponses get()
           
 ClusterNodeResponses get(long timeout, TimeUnit timeUnit)
           
 BlockingQueue<ClusterNodeResponse> getPartialResults()
           
 boolean isCancelled()
           
 boolean isDone()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

FutureClusterResponses

public FutureClusterResponses(List<Address> addresses)
Method Detail

addClusterNodeResponse

public void addClusterNodeResponse(ClusterNodeResponse clusterNodeResponse)

addExpectedReplyAddress

public void addExpectedReplyAddress(Address address)

cancel

public boolean cancel(boolean mayInterruptIfRunning)
Specified by:
cancel in interface Future<ClusterNodeResponses>

expectsReply

public boolean expectsReply(Address address)

get

public ClusterNodeResponses get()
                         throws InterruptedException
Specified by:
get in interface Future<ClusterNodeResponses>
Throws:
InterruptedException

get

public ClusterNodeResponses get(long timeout,
                                TimeUnit timeUnit)
                         throws InterruptedException,
                                TimeoutException
Specified by:
get in interface Future<ClusterNodeResponses>
Throws:
InterruptedException
TimeoutException

getPartialResults

public BlockingQueue<ClusterNodeResponse> getPartialResults()

isCancelled

public boolean isCancelled()
Specified by:
isCancelled in interface Future<ClusterNodeResponses>

isDone

public boolean isDone()
Specified by:
isDone in interface Future<ClusterNodeResponses>

Liferay 6.2-ce-ga5