public class MessageSerializer
extends java.lang.Object
implements akka.serialization.BaseSerializer
PersistentRepr
, AtLeastOnceDelivery
and PersistentFSM.StateChangeEvent
messages.Constructor and Description |
---|
MessageSerializer(akka.actor.ExtendedActorSystem system) |
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.Class<AtomicWrite> AtomicWriteClass()
public java.lang.Class<PersistentRepr> PersistentReprClass()
public java.lang.Class<PersistentImpl> PersistentImplClass()
public java.lang.Class<AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot> AtLeastOnceDeliverySnapshotClass()
public java.lang.Class<PersistentFSM.StateChangeEvent> PersistentStateChangeEventClass()
public boolean includeManifest()
includeManifest
in interface akka.serialization.Serializer
public byte[] toBinary(java.lang.Object o)
akka.serialization.Serializer
.toBinary
in interface akka.serialization.Serializer
o
- (undocumented)public Message fromBinary(byte[] bytes, scala.Option<java.lang.Class<?>> manifest)
akka.serialization.Serializer
.fromBinary
in interface akka.serialization.Serializer
bytes
- (undocumented)manifest
- (undocumented)public MessageFormats.AtLeastOnceDeliverySnapshot.Builder atLeastOnceDeliverySnapshotBuilder(AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot snap)
public MessageFormats.PersistentStateChangeEvent.Builder stateChangeBuilder(PersistentFSM.StateChangeEvent stateChange)
public AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot atLeastOnceDeliverySnapshot(MessageFormats.AtLeastOnceDeliverySnapshot atLeastOnceDeliverySnapshot)
public PersistentFSM.StateChangeEvent stateChange(MessageFormats.PersistentStateChangeEvent persistentStateChange)