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

Constructor Summary

ClusterRequestReceiver(ClusterExecutorImpl clusterExecutorImpl)

Method Summary

protected void	doReceive(org.jgroups.Message message)
protected void	doViewAccepted(org.jgroups.View oldView, org.jgroups.View newView)
protected List<Address>	getDepartAddresses(org.jgroups.View oldView, org.jgroups.View newView)
protected List<Address>	getNewAddresses(org.jgroups.View oldView, org.jgroups.View newView)
protected void	handleResponse(Address address, ClusterRequest clusterRequest, Object returnValue, Exception exception)
protected void	processClusterRequest(ClusterRequest clusterRequest, Address sourceAddress)
protected void	processClusterResponse(ClusterNodeResponse clusterNodeResponse, Address sourceAddress)
protected boolean	processLocalMessage(Object message)

Methods inherited from class com.liferay.portal.cluster.BaseReceiver

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

Constructor Detail

ClusterRequestReceiver

public ClusterRequestReceiver(ClusterExecutorImpl clusterExecutorImpl)

Method Detail

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

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)