org.jboss.cache.remoting.jgroups
Class CacheMessageListener

java.lang.Object
  org.jboss.cache.remoting.jgroups.CacheMessageListener

All Implemented Interfaces:

org.jgroups.ExtendedMessageListener, org.jgroups.MessageListener

public class CacheMessageListener
extends Object
implements org.jgroups.ExtendedMessageListener

JGroups MessageListener

Since:

2.1.0

Author:

Manik Surtani (manik@jboss.org)

Field Summary

protected Exception

setStateException Reference to an exception that was raised during state installation on this node.

Constructor Summary

CacheMessageListener()

Method Summary

byte[]	getState()
void	getState(OutputStream ostream)
byte[]	getState(String state_id)
void	getState(String state_id, OutputStream ostream)
boolean	isStateSet()
void	receive(org.jgroups.Message msg) Callback, does nothing.
void	setState(byte[] new_state)
void	setState(InputStream istream)
void	setState(String state_id, byte[] state)
void	setState(String state_id, InputStream istream)
void	setStateSet(boolean stateSet)
protected void	stateProducingFailed(Throwable t)
protected void	stateReceivedSuccess()
protected void	stateReceivingFailed(Throwable t)
void	waitForState()

Methods inherited from class java.lang.Object

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

Field Detail

setStateException

protected volatile Exception setStateException

Reference to an exception that was raised during state installation on this node.

Constructor Detail

CacheMessageListener

public CacheMessageListener()

Method Detail

isStateSet

public boolean isStateSet()

setStateSet

public void setStateSet(boolean stateSet)

waitForState

public void waitForState()
                  throws Exception

Throws:

Exception

stateReceivedSuccess

protected void stateReceivedSuccess()

stateReceivingFailed

protected void stateReceivingFailed(Throwable t)

stateProducingFailed

protected void stateProducingFailed(Throwable t)

receive

public void receive(org.jgroups.Message msg)

Callback, does nothing.

Specified by:

receive in interface org.jgroups.MessageListener

getState

public byte[] getState()

Specified by:

getState in interface org.jgroups.MessageListener

setState

public void setState(byte[] new_state)

Specified by:

setState in interface org.jgroups.MessageListener

getState

public byte[] getState(String state_id)

Specified by:

getState in interface org.jgroups.ExtendedMessageListener

getState

public void getState(OutputStream ostream)

Specified by:

getState in interface org.jgroups.ExtendedMessageListener

getState

public void getState(String state_id,
                     OutputStream ostream)

Specified by:

getState in interface org.jgroups.ExtendedMessageListener

setState

public void setState(InputStream istream)

Specified by:

setState in interface org.jgroups.ExtendedMessageListener

setState

public void setState(String state_id,
                     byte[] state)

Specified by:

setState in interface org.jgroups.ExtendedMessageListener

setState

public void setState(String state_id,
                     InputStream istream)

Specified by:

setState in interface org.jgroups.ExtendedMessageListener