Liferay 6.2-ce-ga5

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, PortalPortProtocolEventListener

public class ClusterExecutorImpl
extends ClusterBase
implements ClusterExecutor, PortalPortEventListener, PortalPortProtocolEventListener


Field Summary
static String CLUSTER_EXECUTOR_CALLBACK_THREAD_POOL
           
 
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)
           
 void execute(ClusterRequest clusterRequest, ClusterResponseCallback clusterResponseCallback)
           
 void execute(ClusterRequest clusterRequest, ClusterResponseCallback clusterResponseCallback, long timeout, TimeUnit timeUnit)
           
protected  void fireClusterEvent(ClusterEvent clusterEvent)
           
protected  ClusterNodeResponse generateClusterNodeResponse(ClusterRequest clusterRequest, Object returnValue, Exception exception)
           
 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)
           
protected  boolean isShortcutLocalMethod()
           
protected  void memberJoined(Address joinAddress, ClusterNode clusterNode)
           
protected  void memberRemoved(List<Address> departAddresses)
           
 void portalPortConfigured(int port)
          Deprecated. As of 6.2.0, replaced by portalPortProtocolConfigured(int, Boolean)
 void portalPortProtocolConfigured(int port, Boolean secure)
           
protected  List<Address> prepareAddresses(ClusterRequest clusterRequest)
           
 void removeClusterEventListener(ClusterEventListener clusterEventListener)
           
protected  void runLocalMethod(ClusterRequest clusterRequest, FutureClusterResponses futureClusterResponses)
           
protected  void sendNotifyRequest()
           
 void setClusterEventListeners(List<ClusterEventListener> clusterEventListeners)
           
 void setShortcutLocalMethod(boolean shortcutLocalMethod)
           
 
Methods inherited from class com.liferay.portal.cluster.ClusterBase
createJChannel, getAddresses, initBindAddress, initSystemProperties, isEnabled, sendJGroupsMessage
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface com.liferay.portal.kernel.cluster.ClusterExecutor
isEnabled
 

Field Detail

CLUSTER_EXECUTOR_CALLBACK_THREAD_POOL

public static final String CLUSTER_EXECUTOR_CALLBACK_THREAD_POOL
See Also:
Constant Field Values
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

execute

public void execute(ClusterRequest clusterRequest,
                    ClusterResponseCallback clusterResponseCallback)
             throws SystemException
Specified by:
execute in interface ClusterExecutor
Throws:
SystemException

execute

public void execute(ClusterRequest clusterRequest,
                    ClusterResponseCallback clusterResponseCallback,
                    long timeout,
                    TimeUnit timeUnit)
             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

portalPortConfigured

public void portalPortConfigured(int port)
Deprecated. As of 6.2.0, replaced by portalPortProtocolConfigured(int, Boolean)

Specified by:
portalPortConfigured in interface PortalPortEventListener

portalPortProtocolConfigured

public void portalPortProtocolConfigured(int port,
                                         Boolean secure)
Specified by:
portalPortProtocolConfigured in interface PortalPortProtocolEventListener

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)

generateClusterNodeResponse

protected ClusterNodeResponse generateClusterNodeResponse(ClusterRequest clusterRequest,
                                                          Object returnValue,
                                                          Exception exception)

getControlChannel

protected org.jgroups.JChannel getControlChannel()

getExecutionResults

protected FutureClusterResponses getExecutionResults(String uuid)

initChannels

protected void initChannels()
                     throws Exception
Specified by:
initChannels in class ClusterBase
Throws:
Exception

initLocalClusterNode

protected void initLocalClusterNode()
                             throws Exception
Throws:
Exception

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 void runLocalMethod(ClusterRequest clusterRequest,
                              FutureClusterResponses futureClusterResponses)

sendNotifyRequest

protected void sendNotifyRequest()

Liferay 6.2-ce-ga5