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 com.liferay.portal.cluster.BaseReceiver |
block, getCoordinator, getState, getView, openLatch, receive, retrievePayload, setState, suspect, unblock, viewAccepted |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ClusterRequestReceiver
public ClusterRequestReceiver(ClusterExecutorImpl clusterExecutorImpl)
doReceive
protected void doReceive(org.jgroups.Message message)
- Specified by:
doReceive in class BaseReceiver
doViewAccepted
protected void doViewAccepted(org.jgroups.View oldView,
org.jgroups.View newView)
- Overrides:
doViewAccepted in class BaseReceiver
doCoordinatorUpdated
protected void doCoordinatorUpdated(org.jgroups.Address coordinator)
- Overrides:
doCoordinatorUpdated in class BaseReceiver
getDepartAddresses
protected List<Address> getDepartAddresses(org.jgroups.View oldView,
org.jgroups.View newView)
getNewAddresses
protected List<Address> getNewAddresses(org.jgroups.View oldView,
org.jgroups.View newView)
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)