com.liferay.portal.kernel.cluster
Class FutureClusterResponses

java.lang.Object
  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>