com.liferay.portal.cluster
Class ClusterExecutorImpl

java.lang.Object
  com.liferay.portal.cluster.ClusterBase
      com.liferay.portal.cluster.ClusterExecutorImpl

All Implemented Interfaces:

ClusterExecutor, PortalPortEventListener

public class ClusterExecutorImpl
extends ClusterBase
implements ClusterExecutor, PortalPortEventListener

Field Summary

Fields inherited from class com.liferay.portal.cluster.ClusterBase

bindInetAddress

Constructor Summary

ClusterExecutorImpl()

Method Summary

void	addClusterEventListener(ClusterEventListener clusterEventListener)
void	afterPropertiesSet()
void	destroy()
FutureClusterResponses	execute(ClusterRequest clusterRequest)
protected void	fireClusterEvent(ClusterEvent clusterEvent)
List<ClusterEventListener>	getClusterEventListeners()
List<ClusterNode>	getClusterNodes()
protected org.jgroups.JChannel	getControlChannel()
protected FutureClusterResponses	getExecutionResults(String uuid)
ClusterNode	getLocalClusterNode()
protected Address	getLocalControlAddress()
protected void	initChannels()
void	initialize()
boolean	isClusterNodeAlive(String clusterNodeId)
boolean	isEnabled()
protected boolean	isShortcutLocalMethod()
protected void	memberJoined(Address joinAddress, ClusterNode clusterNode)
protected void	memberRemoved(List<Address> departAddresses)
void	portalPortConfigured(int port)
protected List<Address>	prepareAddresses(ClusterRequest clusterRequest)
void	removeClusterEventListener(ClusterEventListener clusterEventListener)
protected ClusterNodeResponse	runLocalMethod(MethodHandler methodHandler)
protected void	sendMulticastRequest(ClusterRequest clusterRequest)
protected void	sendUnicastRequest(ClusterRequest clusterRequest, List<Address> addresses)
void	setClusterEventListeners(List<ClusterEventListener> clusterEventListeners)
void	setShortcutLocalMethod(boolean shortcutLocalMethod)

Methods inherited from class com.liferay.portal.cluster.ClusterBase

createJChannel, getAddresses, initBindAddress, initSystemProperties

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterExecutorImpl

public ClusterExecutorImpl()

Method Detail

addClusterEventListener

public void addClusterEventListener(ClusterEventListener clusterEventListener)

Specified by:

addClusterEventListener in interface ClusterExecutor

afterPropertiesSet

public void afterPropertiesSet()

Overrides:

afterPropertiesSet in class ClusterBase

destroy

public void destroy()

Specified by:

destroy in interface ClusterExecutor

Specified by:

destroy in class ClusterBase

execute

public FutureClusterResponses execute(ClusterRequest clusterRequest)
                               throws SystemException

Specified by:

execute in interface ClusterExecutor

Throws:

SystemException

getClusterEventListeners

public List<ClusterEventListener> getClusterEventListeners()

Specified by:

getClusterEventListeners in interface ClusterExecutor

getClusterNodes

public List<ClusterNode> getClusterNodes()

Specified by:

getClusterNodes in interface ClusterExecutor

getLocalClusterNode

public ClusterNode getLocalClusterNode()
                                throws SystemException

Specified by:

getLocalClusterNode in interface ClusterExecutor

Throws:

SystemException

initialize

public void initialize()

Specified by:

initialize in interface ClusterExecutor

isClusterNodeAlive

public boolean isClusterNodeAlive(String clusterNodeId)

Specified by:

isClusterNodeAlive in interface ClusterExecutor

isEnabled

public boolean isEnabled()

Specified by:

isEnabled in interface ClusterExecutor

Overrides:

isEnabled in class ClusterBase

portalPortConfigured

public void portalPortConfigured(int port)

Specified by:

portalPortConfigured in interface PortalPortEventListener

removeClusterEventListener

public void removeClusterEventListener(ClusterEventListener clusterEventListener)

Specified by:

removeClusterEventListener in interface ClusterExecutor

setClusterEventListeners

public void setClusterEventListeners(List<ClusterEventListener> clusterEventListeners)

setShortcutLocalMethod

public void setShortcutLocalMethod(boolean shortcutLocalMethod)

fireClusterEvent

protected void fireClusterEvent(ClusterEvent clusterEvent)

getControlChannel

protected org.jgroups.JChannel getControlChannel()

getExecutionResults

protected FutureClusterResponses getExecutionResults(String uuid)

getLocalControlAddress

protected Address getLocalControlAddress()

initChannels

protected void initChannels()

Specified by:

initChannels in class ClusterBase

isShortcutLocalMethod

protected boolean isShortcutLocalMethod()

memberJoined

protected void memberJoined(Address joinAddress,
                            ClusterNode clusterNode)

memberRemoved

protected void memberRemoved(List<Address> departAddresses)

prepareAddresses

protected List<Address> prepareAddresses(ClusterRequest clusterRequest)

runLocalMethod

protected ClusterNodeResponse runLocalMethod(MethodHandler methodHandler)
                                      throws SystemException

Throws:

SystemException

sendMulticastRequest

protected void sendMulticastRequest(ClusterRequest clusterRequest)
                             throws SystemException

Throws:

SystemException

sendUnicastRequest

protected void sendUnicastRequest(ClusterRequest clusterRequest,
                                  List<Address> addresses)
                           throws SystemException

Throws:

SystemException