com.liferay.portal.kernel.cluster

Class FutureClusterResponses

Object

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>

Author:

Tina Tian

Constructor Summary

Constructors

Constructor and Description
FutureClusterResponses(Set<String> clusterNodeIds)

Method Summary

Modifier and Type	Method and Description
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 FutureTask

cancel, isCancelled, isDone, run, runAndReset

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface 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()