org.springframework.statemachine.zookeeper

Class ZookeeperStateMachinePersist<S,E>

java.lang.Object

org.springframework.statemachine.zookeeper.ZookeeperStateMachinePersist<S,E>

Type Parameters:

S - the type of state

E - the type of event

All Implemented Interfaces:

StateMachinePersist<S,E,org.apache.zookeeper.data.Stat>

public class ZookeeperStateMachinePersist<S,E>
extends java.lang.Object
implements StateMachinePersist<S,E,org.apache.zookeeper.data.Stat>

StateMachinePersist using zookeeper as a storage and kroy libraries as a backing serialization technique.

Author:

Janne Valkealahti

Constructor Summary

Constructors

Constructor and Description
ZookeeperStateMachinePersist(org.apache.curator.framework.CuratorFramework curatorClient, java.lang.String path) Instantiates a new zookeeper state machine persist.
ZookeeperStateMachinePersist(org.apache.curator.framework.CuratorFramework curatorClient, java.lang.String path, java.lang.String logPath, int logSize) Instantiates a new zookeeper state machine persist.

Method Summary

Modifier and Type	Method and Description
StateMachineContext<S,E>	read(org.apache.zookeeper.data.Stat stat) Read a StateMachineContext from a persistent store with a context object T.
StateMachineContext<S,E>	readLog(int version, org.apache.zookeeper.data.Stat stat)
void	write(StateMachineContext<S,E> context, org.apache.zookeeper.data.Stat stat) Write a StateMachineContext into a persistent store with a context object T.

Methods inherited from class java.lang.Object

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

Constructor Detail

ZookeeperStateMachinePersist

public ZookeeperStateMachinePersist(org.apache.curator.framework.CuratorFramework curatorClient,
                                    java.lang.String path)

Instantiates a new zookeeper state machine persist.

Parameters:

curatorClient - the curator client

path - the path for persistent state

ZookeeperStateMachinePersist

public ZookeeperStateMachinePersist(org.apache.curator.framework.CuratorFramework curatorClient,
                                    java.lang.String path,
                                    java.lang.String logPath,
                                    int logSize)

Instantiates a new zookeeper state machine persist.

Parameters:

curatorClient - the curator client

path - the path

logPath - the log path

logSize - the log size

Method Detail

write

public void write(StateMachineContext<S,E> context,
                  org.apache.zookeeper.data.Stat stat)

Description copied from interface: StateMachinePersist

Write a StateMachineContext into a persistent store with a context object T.

Specified by:

write in interface StateMachinePersist<S,E,org.apache.zookeeper.data.Stat>

Parameters:

context - the context

stat - the context ojb

read

public StateMachineContext<S,E> read(org.apache.zookeeper.data.Stat stat)
                              throws java.lang.Exception

Description copied from interface: StateMachinePersist

Read a StateMachineContext from a persistent store with a context object T.

Specified by:

read in interface StateMachinePersist<S,E,org.apache.zookeeper.data.Stat>

Parameters:

stat - the context ojb

Returns:

the state machine context

Throws:

java.lang.Exception - the exception

readLog

public StateMachineContext<S,E> readLog(int version,
                                        org.apache.zookeeper.data.Stat stat)
                                 throws java.lang.Exception

Throws:

java.lang.Exception