akka.remote.serialization
Class ProtobufSerializer

java.lang.Object
  akka.remote.serialization.ProtobufSerializer

All Implemented Interfaces:

Serializer

public class ProtobufSerializer
extends java.lang.Object
implements Serializer

This Serializer serializes com.google.protobuf.Messages

Constructor Summary

ProtobufSerializer()

Method Summary

java.lang.Class<?>[]	ARRAY_OF_BYTE_ARRAY()
static ActorRef	deserializeActorRef(ActorSystem system, RemoteProtocol.ActorRefProtocol 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<?>> 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
static RemoteProtocol.ActorRefProtocol	serializeActorRef(ActorRef ref) Helper to serialize an ActorRef to Akka's protobuf representation.
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

ProtobufSerializer

public ProtobufSerializer()

Method Detail

serializeActorRef

public static RemoteProtocol.ActorRefProtocol serializeActorRef(ActorRef ref)

Helper to serialize an ActorRef to Akka's protobuf representation.

deserializeActorRef

public static ActorRef deserializeActorRef(ActorSystem system,
                                           RemoteProtocol.ActorRefProtocol refProtocol)

Helper to materialize (lookup) an ActorRef from Akka's protobuf representation in the supplied ActorSystem.

ARRAY_OF_BYTE_ARRAY

public java.lang.Class<?>[] ARRAY_OF_BYTE_ARRAY()

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

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

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

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