org.statefulj.persistence.memory

Class MemoryPersisterImpl<T>

java.lang.Object

org.statefulj.persistence.memory.MemoryPersisterImpl<T>

All Implemented Interfaces:

Persister<T>

public class MemoryPersisterImpl<T>
extends Object
implements Persister<T>

Thread safe, in memory Persister.

Author:

Andrew Hall

Constructor Summary

Constructors

Constructor and Description
MemoryPersisterImpl()
MemoryPersisterImpl(Collection<State<T>> states, State<T> startState)
MemoryPersisterImpl(List<State<T>> states, State<T> startState, String stateFieldName)
MemoryPersisterImpl(T stateful, List<State<T>> states, State<T> startState)
MemoryPersisterImpl(T stateful, List<State<T>> states, State<T> startState, String stateFieldName)

Method Summary

Modifier and Type	Method and Description
State<T>	addState(State<T> state)
State<T>	getCurrent(T stateful) Returns the current state.
State<T>	getStartState()
String	getStateFieldName()
Collection<State<T>>	getStates()
State<T>	removeState(State<T> state)
State<T>	removeState(String name)
void	setCurrent(T stateful, State<T> current)
void	setCurrent(T stateful, State<T> current, State<T> next) Set the current state to the next state.
void	setStartState(State<T> startState) Set the Start State
void	setStates(Collection<State<T>> states) Set the Collection of States to be managed by the Persister

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MemoryPersisterImpl

public MemoryPersisterImpl()

MemoryPersisterImpl

public MemoryPersisterImpl(Collection<State<T>> states,
                           State<T> startState)

MemoryPersisterImpl

public MemoryPersisterImpl(List<State<T>> states,
                           State<T> startState,
                           String stateFieldName)

MemoryPersisterImpl

public MemoryPersisterImpl(T stateful,
                           List<State<T>> states,
                           State<T> startState)

MemoryPersisterImpl

public MemoryPersisterImpl(T stateful,
                           List<State<T>> states,
                           State<T> startState,
                           String stateFieldName)

Method Detail

getStates

public Collection<State<T>> getStates()

addState

public State<T> addState(State<T> state)

removeState

public State<T> removeState(State<T> state)

removeState

public State<T> removeState(String name)

setStates

public void setStates(Collection<State<T>> states)

Description copied from interface: Persister

Set the Collection of States to be managed by the Persister

Specified by:

setStates in interface Persister<T>

Parameters:

states - Collection of States

getStartState

public State<T> getStartState()

setStartState

public void setStartState(State<T> startState)

Description copied from interface: Persister

Set the Start State

Specified by:

setStartState in interface Persister<T>

Parameters:

startState - Start State

getStateFieldName

public String getStateFieldName()

getCurrent

public State<T> getCurrent(T stateful)

Description copied from interface: Persister

Returns the current state. This will not call into the underlying database

Specified by:

getCurrent in interface Persister<T>

Parameters:

stateful - Stateful Entity

Returns:

current State of the Stateful Entity

setCurrent

public void setCurrent(T stateful,
                       State<T> current)

setCurrent

public void setCurrent(T stateful,
                       State<T> current,
                       State<T> next)
                throws StaleStateException

Description copied from interface: Persister

Set the current state to the next state. Will serialize access to the persistence and ensure that expected current state is indeed the current state. If not, will throw a StaleStateException

Specified by:

setCurrent in interface Persister<T>

Parameters:

stateful - StatefulEntity

current - Expected current State of the Stateful Entity

next - The value of the updated State

Throws:

StaleStateException - thrown if the state value of the Stateful Entity is not equal to the passed in current value