com.liferay.portal.cluster
Class BaseReceiver

java.lang.Object
  com.liferay.portal.cluster.BaseReceiver

All Implemented Interfaces:

org.jgroups.MembershipListener, org.jgroups.MessageListener, org.jgroups.Receiver

Direct Known Subclasses:

ClusterForwardReceiver, ClusterRequestReceiver

public abstract class BaseReceiver
extends Object
implements org.jgroups.Receiver

Constructor Summary

BaseReceiver()

Method Summary

void	block()
protected abstract void	doReceive(org.jgroups.Message message)
protected void	doViewAccepted(org.jgroups.View oldView, org.jgroups.View newView)
void	getState(OutputStream outputStream)
org.jgroups.View	getView()
void	openLatch()
void	receive(org.jgroups.Message message)
protected Object	retrievePayload(org.jgroups.Message message)
void	setState(InputStream inputStream)
void	suspect(org.jgroups.Address address)
void	unblock()
void	viewAccepted(org.jgroups.View view)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BaseReceiver

public BaseReceiver()

Method Detail

block

public void block()

Specified by:

block in interface org.jgroups.MembershipListener

getState

public void getState(OutputStream outputStream)
              throws Exception

Specified by:

getState in interface org.jgroups.MessageListener

Throws:

Exception

getView

public org.jgroups.View getView()

openLatch

public void openLatch()

receive

public void receive(org.jgroups.Message message)

Specified by:

receive in interface org.jgroups.MessageListener

setState

public void setState(InputStream inputStream)
              throws Exception

Specified by:

setState in interface org.jgroups.MessageListener

Throws:

Exception

suspect

public void suspect(org.jgroups.Address address)

Specified by:

suspect in interface org.jgroups.MembershipListener

unblock

public void unblock()

Specified by:

unblock in interface org.jgroups.MembershipListener

viewAccepted

public void viewAccepted(org.jgroups.View view)

Specified by:

viewAccepted in interface org.jgroups.MembershipListener

doReceive

protected abstract void doReceive(org.jgroups.Message message)

doViewAccepted

protected void doViewAccepted(org.jgroups.View oldView,
                              org.jgroups.View newView)

retrievePayload

protected Object retrievePayload(org.jgroups.Message message)