com.liferay.portal.kernel.cluster
Class ClusterExecutorUtil

java.lang.Object
  com.liferay.portal.kernel.cluster.ClusterExecutorUtil

public class ClusterExecutorUtil
extends Object

Constructor Summary

ClusterExecutorUtil()

Method Summary

static void	addClusterEventListener(ClusterEventListener clusterEventListener)
static void	destroy()
static FutureClusterResponses	execute(ClusterRequest clusterRequest)
static void	execute(ClusterRequest clusterRequest, ClusterResponseCallback clusterResponseCallback)
static void	execute(ClusterRequest clusterRequest, ClusterResponseCallback clusterResponseCallback, long timeout, TimeUnit timeUnit)
static ClusterExecutor	getClusterExecutor()
static List<Address>	getClusterNodeAddresses()
static List<ClusterNode>	getClusterNodes()
static ClusterNode	getLocalClusterNode()
static Address	getLocalClusterNodeAddress()
static void	initialize()
static boolean	isClusterNodeAlive(Address address)
static boolean	isClusterNodeAlive(String clusterNodeId)
static boolean	isEnabled()
static void	removeClusterEventListener(ClusterEventListener clusterEventListener)
void	setClusterExecutor(ClusterExecutor clusterExecutor)

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterExecutorUtil

public ClusterExecutorUtil()

Method Detail

addClusterEventListener

public static void addClusterEventListener(ClusterEventListener clusterEventListener)

destroy

public static void destroy()

execute

public static FutureClusterResponses execute(ClusterRequest clusterRequest)
                                      throws SystemException

Throws:

SystemException

execute

public static void execute(ClusterRequest clusterRequest,
                           ClusterResponseCallback clusterResponseCallback)
                    throws SystemException

Throws:

SystemException

execute

public static void execute(ClusterRequest clusterRequest,
                           ClusterResponseCallback clusterResponseCallback,
                           long timeout,
                           TimeUnit timeUnit)
                    throws SystemException

Throws:

SystemException

getClusterExecutor

public static ClusterExecutor getClusterExecutor()

getClusterNodeAddresses

public static List<Address> getClusterNodeAddresses()

getClusterNodes

public static List<ClusterNode> getClusterNodes()

getLocalClusterNode

public static ClusterNode getLocalClusterNode()
                                       throws SystemException

Throws:

SystemException

getLocalClusterNodeAddress

public static Address getLocalClusterNodeAddress()

initialize

public static void initialize()

isClusterNodeAlive

public static boolean isClusterNodeAlive(Address address)

isClusterNodeAlive

public static boolean isClusterNodeAlive(String clusterNodeId)

isEnabled

public static boolean isEnabled()

removeClusterEventListener

public static void removeClusterEventListener(ClusterEventListener clusterEventListener)

setClusterExecutor

public void setClusterExecutor(ClusterExecutor clusterExecutor)