org.springframework.statemachine.kryo

Class AbstractKryoStateMachineSerialisationService<S,E>

java.lang.Object

org.springframework.statemachine.kryo.AbstractKryoStateMachineSerialisationService<S,E>

Type Parameters:

S - the type of state

E - the type of event

All Implemented Interfaces:

StateMachineSerialisationService<S,E>

Direct Known Subclasses:

KryoStateMachineSerialisationService

public abstract class AbstractKryoStateMachineSerialisationService<S,E>
extends java.lang.Object
implements StateMachineSerialisationService<S,E>

Abstract base implementation for StateMachineSerialisationService using kryo.

Author:

Janne Valkealahti

Field Summary

Fields

Modifier and Type	Field and Description
protected com.esotericsoftware.kryo.pool.KryoPool	pool

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractKryoStateMachineSerialisationService()

Method Summary

Modifier and Type	Method and Description
protected abstract void	configureKryoInstance(com.esotericsoftware.kryo.Kryo kryo) Subclasses implement this to configure the kryo instance.
StateMachineContext<S,E>	deserialiseStateMachineContext(byte[] data) Deserialise state machine context from byte array.
protected abstract <T> T	doDecode(com.esotericsoftware.kryo.Kryo kryo, com.esotericsoftware.kryo.io.Input input, java.lang.Class<T> type) Subclasses implement this method to decode with Kryo.
protected abstract void	doEncode(com.esotericsoftware.kryo.Kryo kryo, java.lang.Object object, com.esotericsoftware.kryo.io.Output output) Subclasses implement this method to encode with Kryo.
byte[]	serialiseStateMachineContext(StateMachineContext<S,E> context) Serialise state machine context into byte array.

Methods inherited from class java.lang.Object

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

Field Detail

pool

protected final com.esotericsoftware.kryo.pool.KryoPool pool

Constructor Detail

AbstractKryoStateMachineSerialisationService

protected AbstractKryoStateMachineSerialisationService()

Method Detail

serialiseStateMachineContext

public byte[] serialiseStateMachineContext(StateMachineContext<S,E> context)
                                    throws java.lang.Exception

Description copied from interface: StateMachineSerialisationService

Serialise state machine context into byte array.

Specified by:

serialiseStateMachineContext in interface StateMachineSerialisationService<S,E>

Parameters:

context - the context

Returns:

the data as byte[]

Throws:

java.lang.Exception - the exception when serialisation fails

deserialiseStateMachineContext

public StateMachineContext<S,E> deserialiseStateMachineContext(byte[] data)
                                                        throws java.lang.Exception

Description copied from interface: StateMachineSerialisationService

Deserialise state machine context from byte array.

Specified by:

deserialiseStateMachineContext in interface StateMachineSerialisationService<S,E>

Parameters:

data - the data

Returns:

the state machine context

Throws:

java.lang.Exception - the exception when deserialisation fails

doEncode

protected abstract void doEncode(com.esotericsoftware.kryo.Kryo kryo,
                                 java.lang.Object object,
                                 com.esotericsoftware.kryo.io.Output output)

Subclasses implement this method to encode with Kryo.

Parameters:

kryo - the Kryo instance

object - the object to encode

output - the Kryo Output instance

doDecode

protected abstract <T> T doDecode(com.esotericsoftware.kryo.Kryo kryo,
                                  com.esotericsoftware.kryo.io.Input input,
                                  java.lang.Class<T> type)

Subclasses implement this method to decode with Kryo.

Type Parameters:

T - the type for decoded object

Parameters:

kryo - the Kryo instance

input - the Kryo Input instance

type - the class of the decoded object

Returns:

the decoded object

configureKryoInstance

protected abstract void configureKryoInstance(com.esotericsoftware.kryo.Kryo kryo)

Subclasses implement this to configure the kryo instance. This is invoked on each new Kryo instance when it is created.

Parameters:

kryo - the kryo instance