com.mulesoft.mule.runtime.module.serialization.kryo.internal.protocol

Class KryoSerializationProtocol

java.lang.Object

org.mule.runtime.core.internal.serialization.AbstractSerializationProtocol

com.mulesoft.mule.runtime.module.serialization.kryo.internal.protocol.KryoSerializationProtocol

All Implemented Interfaces:

org.mule.runtime.api.lifecycle.Initialisable, org.mule.runtime.api.serialization.SerializationProtocol, org.mule.runtime.core.api.context.MuleContextAware

public final class KryoSerializationProtocol
extends org.mule.runtime.core.internal.serialization.AbstractSerializationProtocol
implements org.mule.runtime.api.lifecycle.Initialisable

Implementation of SerializationProtocol that uses the Kryo library to serialize/deserialize, thanks to which this serializer is faster than java's standard and is not limited to objects implementing Serializable. Because a Kryo instance is expensive to allocate, it keeps an internal pool of Kryo instances

Field Summary

Fields inherited from class org.mule.runtime.core.internal.serialization.AbstractSerializationProtocol

muleContext

Fields inherited from interface org.mule.runtime.api.lifecycle.Initialisable

PHASE_NAME

Constructor Summary

Constructors

Constructor and Description
KryoSerializationProtocol(KryoInstanceFactory kryoInstanceFactory, KryoCompressionMode compressionMode) Creates an instances which uses the given compressionMode

Method Summary

Modifier and Type	Method and Description
protected <T> T	doDeserialize(InputStream inputStream, ClassLoader classLoader)
protected byte[]	doSerialize(Object object)
void	initialise()
void	serialize(Object object, OutputStream out)

Methods inherited from class org.mule.runtime.core.internal.serialization.AbstractSerializationProtocol

deserialize, deserialize, deserialize, deserialize, postInitialize, serialize, setMuleContext

Methods inherited from class java.lang.Object

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

Constructor Detail

KryoSerializationProtocol

public KryoSerializationProtocol(KryoInstanceFactory kryoInstanceFactory,
                                 KryoCompressionMode compressionMode)

Creates an instances which uses the given compressionMode

Parameters:

kryoInstanceFactory - creates the Kryo instances required for serialization. Non null.

compressionMode - the desired KryoCompressionMode

Method Detail

initialise

public void initialise()
                throws org.mule.runtime.api.lifecycle.InitialisationException

Specified by:

initialise in interface org.mule.runtime.api.lifecycle.Initialisable

Throws:

org.mule.runtime.api.lifecycle.InitialisationException

serialize

public void serialize(Object object,
                      OutputStream out)
               throws org.mule.runtime.api.serialization.SerializationException

Specified by:

serialize in interface org.mule.runtime.api.serialization.SerializationProtocol

Overrides:

serialize in class org.mule.runtime.core.internal.serialization.AbstractSerializationProtocol

Throws:

org.mule.runtime.api.serialization.SerializationException

doSerialize

protected byte[] doSerialize(Object object)
                      throws Exception

Specified by:

doSerialize in class org.mule.runtime.core.internal.serialization.AbstractSerializationProtocol

Throws:

Exception

doDeserialize

protected <T> T doDeserialize(InputStream inputStream,
                              ClassLoader classLoader)
                       throws Exception

Specified by:

doDeserialize in class org.mule.runtime.core.internal.serialization.AbstractSerializationProtocol

Throws:

Exception