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
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ClusterRequestReceiver
public ClusterRequestReceiver(ClusterExecutorImpl clusterExecutorImpl)
openLatch
public void openLatch()
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
getDepartAddresses
protected List<Address> getDepartAddresses(org.jgroups.View view)
getNewAddresses
protected List<Address> getNewAddresses(org.jgroups.View view)
handleResponse
protected void handleResponse(Address address,
ClusterRequest clusterRequest,
Object returnValue,
Exception exception)
processClusterRequest
protected void processClusterRequest(ClusterRequest clusterRequest,
Address sourceAddress)
processClusterResponse
protected void processClusterResponse(ClusterNodeResponse clusterNodeResponse,
Address sourceAddress)
processLocalMessage
protected boolean processLocalMessage(Object message)