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 |
protected Exception |
setStateException
Reference to an exception that was raised during
state installation on this node. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
setStateException
protected volatile Exception setStateException
- Reference to an exception that was raised during
state installation on this node.
ChannelMessageListener
public ChannelMessageListener()
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
Copyright © 2009 JBoss, a division of Red Hat. All Rights Reserved.