akka.remote.serialization
Class DaemonMsgCreateSerializer

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

All Implemented Interfaces:

akka.serialization.Serializer

public class DaemonMsgCreateSerializer
extends java.lang.Object
implements akka.serialization.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(akka.actor.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)
int	identifier()
boolean	includeManifest()
akka.serialization.Serialization	serialization()
protected com.google.protobuf.ByteString	serialize(java.lang.Object any)
akka.actor.ExtendedActorSystem	system()
byte[]	toBinary(java.lang.Object obj)

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(akka.actor.ExtendedActorSystem system)

Method Detail

system

public akka.actor.ExtendedActorSystem system()

includeManifest

public boolean includeManifest()

Specified by:

includeManifest in interface akka.serialization.Serializer

identifier

public int identifier()

Specified by:

identifier in interface akka.serialization.Serializer

serialization

public akka.serialization.Serialization serialization()

toBinary

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

Specified by:

toBinary in interface akka.serialization.Serializer

fromBinary

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

Specified by:

fromBinary in interface akka.serialization.Serializer

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)