akka.remote.serialization
Class DaemonMsgCreateSerializer

java.lang.Object
  akka.remote.serialization.DaemonMsgCreateSerializer

All Implemented Interfaces:

Serializer

public class DaemonMsgCreateSerializer
extends java.lang.Object
implements Serializer

Serializes akka's internal DaemonMsgCreate using protobuf for the core structure of DaemonMsgCreate, Props and Deploy. Serialization of contained RouterConfig, Config, and Scope is done with configured serializer for those classes, by default java.io.Serializable.

INTERNAL API

Constructor Summary

DaemonMsgCreateSerializer(ExtendedActorSystem system)

Method Summary

protected <T> T	deserialize(com.google.protobuf.ByteString data, java.lang.Class<T> clazz, scala.reflect.ClassTag<T> evidence$1)
java.lang.Object	fromBinary(byte[] bytes, scala.Option<java.lang.Class<?>> clazz) Produces an object from an array of bytes, with an optional type-hint; the class should be loaded using ActorSystem.dynamicAccess.
int	identifier() Completely unique value to identify this implementation of Serializer, used to optimize network traffic Values from 0 to 16 is reserved for Akka internal usage
boolean	includeManifest() Returns whether this serializer needs a manifest in the fromBinary method
Serialization	serialization()
protected com.google.protobuf.ByteString	serialize(java.lang.Object any)
ExtendedActorSystem	system()
byte[]	toBinary(java.lang.Object obj) Serializes the given object into an Array of Byte

Methods inherited from class java.lang.Object

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

Methods inherited from interface akka.serialization.Serializer

fromBinary, fromBinary

Constructor Detail

DaemonMsgCreateSerializer

public DaemonMsgCreateSerializer(ExtendedActorSystem system)

Method Detail

system

public ExtendedActorSystem system()

includeManifest

public boolean includeManifest()

Description copied from interface: Serializer

Returns whether this serializer needs a manifest in the fromBinary method

Specified by:

includeManifest in interface Serializer

Returns:

(undocumented)

identifier

public int identifier()

Description copied from interface: Serializer

Completely unique value to identify this implementation of Serializer, used to optimize network traffic Values from 0 to 16 is reserved for Akka internal usage

Specified by:

identifier in interface Serializer

Returns:

(undocumented)

serialization

public Serialization serialization()

toBinary

public byte[] toBinary(java.lang.Object obj)

Description copied from interface: Serializer

Serializes the given object into an Array of Byte

Specified by:

toBinary in interface Serializer

Parameters:

obj - (undocumented)

Returns:

(undocumented)

fromBinary

public java.lang.Object fromBinary(byte[] bytes,
                                   scala.Option<java.lang.Class<?>> clazz)

Description copied from interface: Serializer

Produces an object from an array of bytes, with an optional type-hint; the class should be loaded using ActorSystem.dynamicAccess.

Specified by:

fromBinary in interface Serializer

Parameters:

bytes - (undocumented)

clazz - (undocumented)

Returns:

(undocumented)

serialize

protected com.google.protobuf.ByteString serialize(java.lang.Object any)

deserialize

protected <T> T deserialize(com.google.protobuf.ByteString data,
                            java.lang.Class<T> clazz,
                            scala.reflect.ClassTag<T> evidence$1)