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

Field Summary

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

view

Constructor Summary

ClusterRequestReceiver(ClusterExecutorImpl clusterExecutorImpl)

Method Summary

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

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

block, getState, getView, setState, suspect

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

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)