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 List<Address>	getDepartAddresses(org.jgroups.View view)
protected Object	invoke(String servletContextName, MethodHandler methodHandler)
protected void	processClusterRequest(ClusterRequest clusterRequest, org.jgroups.Address sourceAddress, org.jgroups.Address localAddress)
protected void	processClusterResponse(ClusterNodeResponse clusterNodeResponse, org.jgroups.Address sourceAddress, org.jgroups.Address localAddress)
protected boolean	processLocalMessage(Object message, org.jgroups.Address sourceAddress)
void	receive(org.jgroups.Message message)
void	viewAccepted(org.jgroups.View view)

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

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

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 Object invoke(String servletContextName,
                        MethodHandler methodHandler)
                 throws Exception

Throws:

Exception

getDepartAddresses

protected List<Address> getDepartAddresses(org.jgroups.View view)

processClusterRequest

protected void processClusterRequest(ClusterRequest clusterRequest,
                                     org.jgroups.Address sourceAddress,
                                     org.jgroups.Address localAddress)

processClusterResponse

protected void processClusterResponse(ClusterNodeResponse clusterNodeResponse,
                                      org.jgroups.Address sourceAddress,
                                      org.jgroups.Address localAddress)

processLocalMessage

protected boolean processLocalMessage(Object message,
                                      org.jgroups.Address sourceAddress)