Liferay 6.1.10-ee-ga1

com.liferay.portal.cluster
Class ClusterExecutorImpl

java.lang.Object
  extended by com.liferay.portal.cluster.ClusterBase
      extended by 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<Address> getClusterNodeAddresses()
           
 List<ClusterNode> getClusterNodes()
           
protected  org.jgroups.JChannel getControlChannel()
           
protected  FutureClusterResponses getExecutionResults(String uuid)
           
 ClusterNode getLocalClusterNode()
           
 Address getLocalClusterNodeAddress()
           
protected  void initChannels()
           
 void initialize()
           
protected  void initLocalClusterNode()
           
 boolean isClusterNodeAlive(Address address)
           
 boolean isClusterNodeAlive(String clusterNodeId)
           
 boolean isEnabled()
           
protected  boolean isShortcutLocalMethod()
           
protected  void notify(Address address, ClusterNode clusterNode, long expirationTime)
           
 void portalPortConfigured(int port)
           
protected  List<Address> prepareAddresses(ClusterRequest clusterRequest)
           
 void removeClusterEventListener(ClusterEventListener clusterEventListener)
           
protected  void removeExpiredInstances()
           
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

getClusterNodeAddresses

public List<Address> getClusterNodeAddresses()
Specified by:
getClusterNodeAddresses in interface ClusterExecutor

getClusterNodes

public List<ClusterNode> getClusterNodes()
Specified by:
getClusterNodes in interface ClusterExecutor

getLocalClusterNode

public ClusterNode getLocalClusterNode()
Specified by:
getLocalClusterNode in interface ClusterExecutor

getLocalClusterNodeAddress

public Address getLocalClusterNodeAddress()
Specified by:
getLocalClusterNodeAddress in interface ClusterExecutor

initialize

public void initialize()
Specified by:
initialize in interface ClusterExecutor

isClusterNodeAlive

public boolean isClusterNodeAlive(Address address)
Specified by:
isClusterNodeAlive 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)

initChannels

protected void initChannels()
Specified by:
initChannels in class ClusterBase

initLocalClusterNode

protected void initLocalClusterNode()
                             throws SystemException
Throws:
SystemException

isShortcutLocalMethod

protected boolean isShortcutLocalMethod()

notify

protected void notify(Address address,
                      ClusterNode clusterNode,
                      long expirationTime)

prepareAddresses

protected List<Address> prepareAddresses(ClusterRequest clusterRequest)

removeExpiredInstances

protected void removeExpiredInstances()

runLocalMethod

protected ClusterNodeResponse runLocalMethod(MethodHandler methodHandler)

sendMulticastRequest

protected void sendMulticastRequest(ClusterRequest clusterRequest)
                             throws SystemException
Throws:
SystemException

sendUnicastRequest

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

Liferay 6.1.10-ee-ga1