org.jboss.cache.remoting.jgroups
Class ChannelMessageListener

java.lang.Object
  extended by 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.
 
Constructor Summary
ChannelMessageListener()
           
 
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 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


Copyright © 2009 JBoss, a division of Red Hat. All Rights Reserved.