org.codehaus.wadi.dindex.impl
Class SimpleStateManager
java.lang.Object
org.codehaus.wadi.dindex.impl.SimpleStateManager
- All Implemented Interfaces:
- StateManager
- public class SimpleStateManager
- extends Object
- implements StateManager
Method Summary |
void |
acceptImmigrant(ObjectMessage message,
Location location,
String name,
Motable motable)
|
void |
init(StateManagerConfig config)
|
boolean |
offerEmigrant(String key,
Motable emotable,
long timeout)
|
void |
onDIndexDeletionRequest(ObjectMessage om,
DeleteIMToPM request)
|
void |
onDIndexForwardRequest(ObjectMessage om,
DIndexForwardRequest request)
|
void |
onDIndexInsertionRequest(ObjectMessage om,
InsertIMToPM request)
|
void |
onDIndexRelocationRequest(ObjectMessage om,
DIndexRelocationRequest request)
|
void |
onEmigrationRequest(ObjectMessage message,
ReleaseEntryRequest request)
|
void |
onMessage(ObjectMessage message,
MoveIMToPM request)
|
void |
onMessage(ObjectMessage message1,
MovePMToSM request)
|
void |
setImmigrationListener(StateManager.ImmigrationListener listener)
|
void |
start()
|
void |
stop()
|
void |
unsetImmigrationListener(StateManager.ImmigrationListener listener)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
_lockLog
protected final Log _lockLog
_dispatcher
protected final Dispatcher _dispatcher
_inactiveTime
protected final long _inactiveTime
_resTimeout
protected final int _resTimeout
- See Also:
- Constant Field Values
_config
protected StateManagerConfig _config
_log
protected Log _log
_listener
protected StateManager.ImmigrationListener _listener
SimpleStateManager
public SimpleStateManager(Dispatcher dispatcher,
long inactiveTime)
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
onDIndexInsertionRequest
public void onDIndexInsertionRequest(ObjectMessage om,
InsertIMToPM request)
onDIndexDeletionRequest
public void onDIndexDeletionRequest(ObjectMessage om,
DeleteIMToPM request)
onDIndexForwardRequest
public void onDIndexForwardRequest(ObjectMessage om,
DIndexForwardRequest request)
onDIndexRelocationRequest
public void onDIndexRelocationRequest(ObjectMessage om,
DIndexRelocationRequest request)
onMessage
public void onMessage(ObjectMessage message,
MoveIMToPM request)
onMessage
public void onMessage(ObjectMessage message1,
MovePMToSM request)
offerEmigrant
public boolean offerEmigrant(String key,
Motable emotable,
long timeout)
- Specified by:
offerEmigrant
in interface StateManager
acceptImmigrant
public void acceptImmigrant(ObjectMessage message,
Location location,
String name,
Motable motable)
- Specified by:
acceptImmigrant
in interface StateManager
setImmigrationListener
public void setImmigrationListener(StateManager.ImmigrationListener listener)
- Specified by:
setImmigrationListener
in interface StateManager
unsetImmigrationListener
public void unsetImmigrationListener(StateManager.ImmigrationListener listener)
- Specified by:
unsetImmigrationListener
in interface StateManager
onEmigrationRequest
public void onEmigrationRequest(ObjectMessage message,
ReleaseEntryRequest request)
Copyright © 2004-2006 Core Developers Network Ltd.. All Rights Reserved.