public class ProtobufSerializer
extends java.lang.Object
implements akka.serialization.BaseSerializer
akka.protobuf.Message
and com.google.protobuf.Message
It is using reflection to find the parseFrom
and toByteArray
methods to avoid
dependency to com.google.protobuf
.Constructor and Description |
---|
ProtobufSerializer() |
ProtobufSerializer(akka.actor.ExtendedActorSystem system) |
Modifier and Type | Method and Description |
---|---|
java.lang.Class<?>[] |
ARRAY_OF_BYTE_ARRAY() |
static akka.actor.ActorRef |
deserializeActorRef(akka.actor.ExtendedActorSystem system,
WireFormats.ActorRefData refProtocol)
Helper to materialize (lookup) an
ActorRef
from Akka's protobuf representation in the supplied
ActorSystem . |
java.lang.Object |
fromBinary(byte[] bytes,
scala.Option<java.lang.Class<?>> manifest) |
int |
identifier() |
boolean |
includeManifest() |
static WireFormats.ActorRefData |
serializeActorRef(akka.actor.ActorRef ref)
Helper to serialize an
ActorRef to Akka's
protobuf representation. |
akka.actor.ExtendedActorSystem |
system() |
byte[] |
toBinary(java.lang.Object obj) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public ProtobufSerializer(akka.actor.ExtendedActorSystem system)
public ProtobufSerializer()
public static WireFormats.ActorRefData serializeActorRef(akka.actor.ActorRef ref)
ActorRef
to Akka's
protobuf representation.ref
- (undocumented)public static akka.actor.ActorRef deserializeActorRef(akka.actor.ExtendedActorSystem system, WireFormats.ActorRefData refProtocol)
ActorRef
from Akka's protobuf representation in the supplied
ActorSystem
.system
- (undocumented)refProtocol
- (undocumented)public akka.actor.ExtendedActorSystem system()
system
in interface akka.serialization.BaseSerializer
public int identifier()
identifier
in interface akka.serialization.BaseSerializer
identifier
in interface akka.serialization.Serializer
public java.lang.Class<?>[] ARRAY_OF_BYTE_ARRAY()
public boolean includeManifest()
includeManifest
in interface akka.serialization.Serializer
public java.lang.Object fromBinary(byte[] bytes, scala.Option<java.lang.Class<?>> manifest)
fromBinary
in interface akka.serialization.Serializer
public byte[] toBinary(java.lang.Object obj)
toBinary
in interface akka.serialization.Serializer