com.liferay.portal.cluster
Class ClusterRequestReceiver
java.lang.Object
com.liferay.portal.cluster.BaseReceiver
com.liferay.portal.cluster.ClusterRequestReceiver
- All Implemented Interfaces:
- org.jgroups.MembershipListener, org.jgroups.MessageListener, org.jgroups.Receiver
public class ClusterRequestReceiver
- extends BaseReceiver
View Source
- Author:
- Michael C. Han, Tina Tian
Method Summary |
protected java.util.List<com.liferay.portal.kernel.cluster.Address> |
getDepartAddresses(org.jgroups.View view)
|
protected java.lang.Object |
invoke(java.lang.String servletContextName,
com.liferay.portal.kernel.util.MethodHandler methodHandler)
|
protected void |
processClusterRequest(com.liferay.portal.kernel.cluster.ClusterRequest clusterRequest,
org.jgroups.Address sourceAddress,
org.jgroups.Address localAddress)
|
protected void |
processClusterResponse(com.liferay.portal.kernel.cluster.ClusterNodeResponse clusterNodeResponse,
org.jgroups.Address sourceAddress,
org.jgroups.Address localAddress)
|
protected boolean |
processLocalMessage(java.lang.Object message,
org.jgroups.Address sourceAddress)
|
void |
receive(org.jgroups.Message message)
|
void |
viewAccepted(org.jgroups.View view)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ClusterRequestReceiver
public ClusterRequestReceiver(ClusterExecutorImpl clusterExecutorImpl)
receive
public void receive(org.jgroups.Message message)
- Specified by:
receive
in interface org.jgroups.MessageListener
- Overrides:
receive
in class BaseReceiver
viewAccepted
public void viewAccepted(org.jgroups.View view)
- Specified by:
viewAccepted
in interface org.jgroups.MembershipListener
- Overrides:
viewAccepted
in class BaseReceiver
invoke
protected java.lang.Object invoke(java.lang.String servletContextName,
com.liferay.portal.kernel.util.MethodHandler methodHandler)
throws java.lang.Exception
- Throws:
java.lang.Exception
getDepartAddresses
protected java.util.List<com.liferay.portal.kernel.cluster.Address> getDepartAddresses(org.jgroups.View view)
processClusterRequest
protected void processClusterRequest(com.liferay.portal.kernel.cluster.ClusterRequest clusterRequest,
org.jgroups.Address sourceAddress,
org.jgroups.Address localAddress)
processClusterResponse
protected void processClusterResponse(com.liferay.portal.kernel.cluster.ClusterNodeResponse clusterNodeResponse,
org.jgroups.Address sourceAddress,
org.jgroups.Address localAddress)
processLocalMessage
protected boolean processLocalMessage(java.lang.Object message,
org.jgroups.Address sourceAddress)