org.jboss.cache
Class CacheImpl.MessageListenerAdaptor

java.lang.Object
  extended by org.jboss.cache.CacheImpl.MessageListenerAdaptor
All Implemented Interfaces:
org.jgroups.ExtendedMessageListener, org.jgroups.MessageListener
Enclosing class:
CacheImpl<K,V>

protected class CacheImpl.MessageListenerAdaptor
extends java.lang.Object
implements org.jgroups.ExtendedMessageListener


Field Summary
protected  java.lang.Exception setStateException
          Reference to an exception that was raised during state installation on this node.
 
Constructor Summary
protected CacheImpl.MessageListenerAdaptor()
           
 
Method Summary
 byte[] getState()
           
 void getState(java.io.OutputStream ostream)
           
 byte[] getState(java.lang.String state_id)
           
 void getState(java.lang.String state_id, java.io.OutputStream ostream)
           
 void receive(org.jgroups.Message msg)
          Callback, does nothing.
 void setState(byte[] new_state)
           
 void setState(java.io.InputStream istream)
           
 void setState(java.lang.String state_id, byte[] state)
           
 void setState(java.lang.String state_id, java.io.InputStream istream)
           
protected  void stateProducingFailed(java.lang.Throwable t)
           
protected  void stateReceivedSuccess()
           
protected  void stateReceivingFailed(java.lang.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 java.lang.Exception setStateException
Reference to an exception that was raised during state installation on this node.

Constructor Detail

CacheImpl.MessageListenerAdaptor

protected CacheImpl.MessageListenerAdaptor()
Method Detail

waitForState

public void waitForState()
                  throws java.lang.Exception
Throws:
java.lang.Exception

stateReceivedSuccess

protected void stateReceivedSuccess()

stateReceivingFailed

protected void stateReceivingFailed(java.lang.Throwable t)

stateProducingFailed

protected void stateProducingFailed(java.lang.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(java.lang.String state_id)
Specified by:
getState in interface org.jgroups.ExtendedMessageListener

getState

public void getState(java.io.OutputStream ostream)
Specified by:
getState in interface org.jgroups.ExtendedMessageListener

getState

public void getState(java.lang.String state_id,
                     java.io.OutputStream ostream)
Specified by:
getState in interface org.jgroups.ExtendedMessageListener

setState

public void setState(java.io.InputStream istream)
Specified by:
setState in interface org.jgroups.ExtendedMessageListener

setState

public void setState(java.lang.String state_id,
                     byte[] state)
Specified by:
setState in interface org.jgroups.ExtendedMessageListener

setState

public void setState(java.lang.String state_id,
                     java.io.InputStream istream)
Specified by:
setState in interface org.jgroups.ExtendedMessageListener