org.apache.s4.comm.serialize
Class KryoSerDeser

java.lang.Object
  extended by org.apache.s4.comm.serialize.KryoSerDeser
All Implemented Interfaces:
SerializerDeserializer

public class KryoSerDeser
extends java.lang.Object
implements SerializerDeserializer

Serializazer/deserializer based on kryo


Constructor Summary
KryoSerDeser()
           
KryoSerDeser(java.lang.ClassLoader classLoader)
           
 
Method Summary
 java.lang.Object deserialize(byte[] rawMessage)
           
 byte[] serialize(java.lang.Object message)
           
 void setInitialBufferSize(int initialBufferSize)
           
 void setMaxBufferSize(int maxBufferSize)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

KryoSerDeser

public KryoSerDeser()

KryoSerDeser

public KryoSerDeser(java.lang.ClassLoader classLoader)
Parameters:
classLoader - classloader able to handle classes to serialize/deserialize. For instance, application-level events can only be handled by the application classloader.
Method Detail

setInitialBufferSize

public void setInitialBufferSize(int initialBufferSize)

setMaxBufferSize

public void setMaxBufferSize(int maxBufferSize)

deserialize

public java.lang.Object deserialize(byte[] rawMessage)
Specified by:
deserialize in interface SerializerDeserializer

serialize

public byte[] serialize(java.lang.Object message)
Specified by:
serialize in interface SerializerDeserializer