org.jboss.cache.remoting.jgroups

Class ChannelMessageListener

java.lang.Object

org.jboss.cache.remoting.jgroups.ChannelMessageListener

All Implemented Interfaces:

org.jgroups.ExtendedMessageListener, org.jgroups.MessageListener

public class ChannelMessageListener
extends Object
implements org.jgroups.ExtendedMessageListener

JGroups MessageListener

Since:

2.1.0

Author:

Manik Surtani (manik AT jboss DOT org)

Field Summary

Fields

Modifier and Type	Field and Description
protected Exception	setStateException Reference to an exception that was raised during state installation on this node.

Constructor Summary

Constructors

Constructor and Description
ChannelMessageListener()

Method Summary

Methods

Modifier and Type	Method and Description
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 stateId, 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

ChannelMessageListener

public ChannelMessageListener()

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 stateId,
            InputStream istream)

Specified by:

setState in interface org.jgroups.ExtendedMessageListener