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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CLUSTER_EXECUTOR_CALLBACK_THREAD_POOL
public static final String CLUSTER_EXECUTOR_CALLBACK_THREAD_POOL
- See Also:
- Constant Field Values
ClusterExecutorImpl
public ClusterExecutorImpl()
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)
- 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)
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 org.jgroups.ChannelException
- Specified by:
initChannels
in class ClusterBase
- Throws:
org.jgroups.ChannelException
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()