public class ReplicatorMessageSerializer extends akka.serialization.SerializerWithStringManifest implements SerializationSupport, akka.serialization.BaseSerializer
Constructor and Description |
---|
ReplicatorMessageSerializer(akka.actor.ExtendedActorSystem system) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
ChangedManifest() |
java.lang.String |
DataEnvelopeManifest() |
java.lang.Object |
fromBinary(byte[] bytes,
java.lang.String manifest) |
java.lang.String |
GetFailureManifest() |
java.lang.String |
GetManifest() |
java.lang.String |
GetSuccessManifest() |
java.lang.String |
GossipManifest() |
java.lang.String |
manifest(java.lang.Object obj) |
java.lang.String |
NotFoundManifest() |
java.lang.String |
ReadManifest() |
java.lang.String |
ReadResultManifest() |
java.lang.String |
StatusManifest() |
java.lang.String |
SubscribeManifest() |
akka.actor.ExtendedActorSystem |
system() |
byte[] |
toBinary(java.lang.Object obj) |
java.lang.String |
UnsubscribeManifest() |
java.lang.String |
WriteAckManifest() |
java.lang.String |
WriteManifest() |
fromBinary, fromBinary, fromBinary, identifier, includeManifest
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addressFromProto, addressProtocol, addressToProto, BufferSize, compress, decompress, otherMessageFromBinary, otherMessageFromProto, otherMessageToProto, protocol, resolveActorRef, ser, serialization, transportInfo, transportInformation, uniqueAddressFromProto, uniqueAddressToProto
public ReplicatorMessageSerializer(akka.actor.ExtendedActorSystem system)
public akka.actor.ExtendedActorSystem system()
system
in interface SerializationSupport
system
in interface akka.serialization.BaseSerializer
public java.lang.String GetManifest()
public java.lang.String GetSuccessManifest()
public java.lang.String NotFoundManifest()
public java.lang.String GetFailureManifest()
public java.lang.String SubscribeManifest()
public java.lang.String UnsubscribeManifest()
public java.lang.String ChangedManifest()
public java.lang.String DataEnvelopeManifest()
public java.lang.String WriteManifest()
public java.lang.String WriteAckManifest()
public java.lang.String ReadManifest()
public java.lang.String ReadResultManifest()
public java.lang.String StatusManifest()
public java.lang.String GossipManifest()
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 java.lang.Object fromBinary(byte[] bytes, java.lang.String manifest)
fromBinary
in class akka.serialization.SerializerWithStringManifest