org.codehaus.wadi.gridstate.impl
Class IndirectStateManager

java.lang.Object
  extended byorg.codehaus.wadi.gridstate.impl.IndirectStateManager
All Implemented Interfaces:
StateManager

public class IndirectStateManager
extends Object
implements StateManager


Field Summary
protected  String _clusterName
           
protected  StateManagerConfig _config
           
protected  Dispatcher _dispatcher
           
protected  Log _log
           
protected  String _nodeName
           
protected  long _timeout
           
 
Constructor Summary
IndirectStateManager(Dispatcher dispatcher, long timeout)
           
 
Method Summary
 Object get(Object key)
           
 void init(StateManagerConfig config)
           
 void onMessage(ObjectMessage message1, MovePMToSM get)
           
 void onMessage(ObjectMessage message1, ReadIMToPM get)
           
 void onMessage(ObjectMessage message1, WriteIMToPM write)
           
 Object put(Object key, Object value, boolean overwrite, boolean returnOldValue)
           
 Object remove(Object key, boolean returnOldValue)
           
 void start()
           
 void stop()
           
 Object syncRpc(Destination destination, Object message)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

_log

protected final Log _log

_clusterName

protected final String _clusterName
See Also:
Constant Field Values

_timeout

protected final long _timeout

_dispatcher

protected final Dispatcher _dispatcher

_nodeName

protected final String _nodeName

_config

protected StateManagerConfig _config
Constructor Detail

IndirectStateManager

public IndirectStateManager(Dispatcher dispatcher,
                            long timeout)
                     throws Exception
Method Detail

init

public void init(StateManagerConfig config)
Specified by:
init in interface StateManager

start

public void start()
           throws Exception
Specified by:
start in interface StateManager
Throws:
Exception

stop

public void stop()
          throws Exception
Specified by:
stop in interface StateManager
Throws:
Exception

get

public Object get(Object key)
Specified by:
get in interface StateManager

onMessage

public void onMessage(ObjectMessage message1,
                      ReadIMToPM get)

onMessage

public void onMessage(ObjectMessage message1,
                      MovePMToSM get)

put

public Object put(Object key,
                  Object value,
                  boolean overwrite,
                  boolean returnOldValue)
Specified by:
put in interface StateManager

onMessage

public void onMessage(ObjectMessage message1,
                      WriteIMToPM write)

remove

public Object remove(Object key,
                     boolean returnOldValue)
Specified by:
remove in interface StateManager

syncRpc

public Object syncRpc(Destination destination,
                      Object message)
               throws Exception
Specified by:
syncRpc in interface StateManager
Throws:
Exception


Copyright © 2004-2006 Core Developers Network Ltd.. All Rights Reserved.