public class MessageSerializer
extends akka.serialization.SerializerWithStringManifest
implements akka.serialization.BaseSerializer
ClusterMetricsMessage
types.Constructor and Description |
---|
MessageSerializer(akka.actor.ExtendedActorSystem system) |
Modifier and Type | Method and Description |
---|---|
byte[] |
compress(akka.protobuf.MessageLite msg) |
byte[] |
decompress(byte[] bytes) |
java.lang.Object |
fromBinary(byte[] bytes,
java.lang.String manifest) |
java.lang.String |
manifest(java.lang.Object obj) |
akka.actor.ExtendedActorSystem |
system() |
byte[] |
toBinary(java.lang.Object obj) |
fromBinary, fromBinary, fromBinary, identifier, includeManifest
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public MessageSerializer(akka.actor.ExtendedActorSystem system)
public akka.actor.ExtendedActorSystem system()
system
in interface akka.serialization.BaseSerializer
public java.lang.String manifest(java.lang.Object obj)
manifest
in class akka.serialization.SerializerWithStringManifest
public byte[] toBinary(java.lang.Object obj)
toBinary
in interface akka.serialization.Serializer
toBinary
in class akka.serialization.SerializerWithStringManifest
public byte[] compress(akka.protobuf.MessageLite msg)
public byte[] decompress(byte[] bytes)
public java.lang.Object fromBinary(byte[] bytes, java.lang.String manifest)
fromBinary
in class akka.serialization.SerializerWithStringManifest