cloud.orbit.actors.runtime

Class KryoSerializer

java.lang.Object

cloud.orbit.actors.runtime.KryoSerializer

All Implemented Interfaces:

ExecutionObjectCloner, ActorExtension, MessageSerializer, Startable

public class KryoSerializer
extends Object
implements ExecutionObjectCloner, MessageSerializer

Kryo based message serializer and object cloning implementation.

Author:

Johno Crawford (johno@sulake.com)

Constructor Summary

Constructors

Constructor and Description
KryoSerializer()
KryoSerializer(Consumer<com.esotericsoftware.kryo.Kryo> kryoConsumer)
KryoSerializer(Consumer<com.esotericsoftware.kryo.Kryo> kryoConsumer, com.esotericsoftware.kryo.ClassResolver classResolver) Deprecated. Do not use this constructor, since it will share a single ClassResolver between Kryo instances in the Kryo pool which can cause concurrency issues.
KryoSerializer(Consumer<com.esotericsoftware.kryo.Kryo> kryoConsumer, Supplier<com.esotericsoftware.kryo.ClassResolver> classResolverSupplier)

Method Summary

Modifier and Type	Method and Description
<T> T	clone(T object)
Message	deserializeMessage(BasicRuntime basicRuntime, byte[] payload)
byte[]	serializeMessage(BasicRuntime basicRuntime, Message message)

Methods inherited from class java.lang.Object

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

Methods inherited from interface cloud.orbit.lifecycle.Startable

start, stop

Constructor Detail

KryoSerializer

public KryoSerializer()

KryoSerializer

public KryoSerializer(Consumer<com.esotericsoftware.kryo.Kryo> kryoConsumer)

KryoSerializer

@Deprecated
public KryoSerializer(Consumer<com.esotericsoftware.kryo.Kryo> kryoConsumer,
                                  com.esotericsoftware.kryo.ClassResolver classResolver)

Deprecated. Do not use this constructor, since it will share a single ClassResolver between Kryo instances in the Kryo pool which can cause concurrency issues.

KryoSerializer

public KryoSerializer(Consumer<com.esotericsoftware.kryo.Kryo> kryoConsumer,
                      Supplier<com.esotericsoftware.kryo.ClassResolver> classResolverSupplier)

Method Detail

deserializeMessage

public Message deserializeMessage(BasicRuntime basicRuntime,
                                  byte[] payload)
                           throws Exception

Specified by:

deserializeMessage in interface MessageSerializer

Throws:

Exception

serializeMessage

public byte[] serializeMessage(BasicRuntime basicRuntime,
                               Message message)
                        throws Exception

Specified by:

serializeMessage in interface MessageSerializer

Throws:

Exception

clone

public <T> T clone(T object)

Specified by:

clone in interface ExecutionObjectCloner