com.liferay.portal.kernel.cluster
Class FutureClusterResponses

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

public class FutureClusterResponses
extends java.lang.Object
implements java.util.concurrent.Future<ClusterNodeResponses>

Author:
Tina Tian

Constructor Summary
FutureClusterResponses(java.util.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, java.util.concurrent.TimeUnit timeUnit)
           
 java.util.concurrent.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(java.util.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 java.util.concurrent.Future<ClusterNodeResponses>

expectsReply

public boolean expectsReply(Address address)

get

public ClusterNodeResponses get()
                         throws java.lang.InterruptedException
Specified by:
get in interface java.util.concurrent.Future<ClusterNodeResponses>
Throws:
java.lang.InterruptedException

get

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

getPartialResults

public java.util.concurrent.BlockingQueue<ClusterNodeResponse> getPartialResults()

isCancelled

public boolean isCancelled()
Specified by:
isCancelled in interface java.util.concurrent.Future<ClusterNodeResponses>

isDone

public boolean isDone()
Specified by:
isDone in interface java.util.concurrent.Future<ClusterNodeResponses>