Package akka.persistence.serialization

Class MessageSerializer

java.lang.Object

akka.persistence.serialization.MessageSerializer

All Implemented Interfaces:

BaseSerializer, Serializer

public class MessageSerializer
extends java.lang.Object
implements BaseSerializer

Serializes persistent messages. Delegates serialization of a persistent message's payload to a matching akka.serialization.Serializer.

Constructor Summary

Constructors

Constructor	Description
MessageSerializer(ExtendedActorSystem system)

Method Summary

Modifier and Type	Method	Description
protected void	akka$serialization$BaseSerializer$_setter_$identifier_$eq(int x$1)
AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot	atLeastOnceDeliverySnapshot(MessageFormats.AtLeastOnceDeliverySnapshot atLeastOnceDeliverySnapshot)
MessageFormats.AtLeastOnceDeliverySnapshot.Builder	atLeastOnceDeliverySnapshotBuilder(AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot snap)
java.lang.Class<AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot>	AtLeastOnceDeliverySnapshotClass()
java.lang.Class<AtomicWrite>	AtomicWriteClass()
Message	fromBinary(byte[] bytes, scala.Option<java.lang.Class<?>> manifest)	Deserializes persistent messages.
int	identifier()	Globally unique serialization identifier configured in the reference.conf.
boolean	includeManifest()	Returns whether this serializer needs a manifest in the fromBinary method
PersistentFSM.PersistentFSMSnapshot<java.lang.Object>	persistentFSMSnapshot(MessageFormats.PersistentFSMSnapshot persistentFSMSnapshot)
MessageFormats.PersistentFSMSnapshot.Builder	persistentFSMSnapshotBuilder(PersistentFSM.PersistentFSMSnapshot<java.lang.Object> persistentFSMSnapshot)
java.lang.Class<PersistentFSM.PersistentFSMSnapshot<java.lang.Object>>	PersistentFSMSnapshotClass()
java.lang.Class<PersistentImpl>	PersistentImplClass()
java.lang.Class<PersistentRepr>	PersistentReprClass()
java.lang.Class<PersistentFSM.StateChangeEvent>	PersistentStateChangeEventClass()
PersistentFSM.StateChangeEvent	stateChange(MessageFormats.PersistentStateChangeEvent persistentStateChange)
MessageFormats.PersistentStateChangeEvent.Builder	stateChangeBuilder(PersistentFSM.StateChangeEvent stateChange)
ExtendedActorSystem	system()	Actor system which is required by most serializer implementations.
byte[]	toBinary(java.lang.Object o)	Serializes persistent messages.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.serialization.BaseSerializer

identifierFromConfig, SerializationIdentifiers

Methods inherited from interface akka.serialization.Serializer

fromBinary, fromBinary

Constructor Detail

MessageSerializer

public MessageSerializer(ExtendedActorSystem system)

Method Detail

AtLeastOnceDeliverySnapshotClass

public java.lang.Class<AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot> AtLeastOnceDeliverySnapshotClass()

AtomicWriteClass

public java.lang.Class<AtomicWrite> AtomicWriteClass()

PersistentFSMSnapshotClass

public java.lang.Class<PersistentFSM.PersistentFSMSnapshot<java.lang.Object>> PersistentFSMSnapshotClass()

PersistentImplClass

public java.lang.Class<PersistentImpl> PersistentImplClass()

PersistentReprClass

public java.lang.Class<PersistentRepr> PersistentReprClass()

PersistentStateChangeEventClass

public java.lang.Class<PersistentFSM.StateChangeEvent> PersistentStateChangeEventClass()

akka$serialization$BaseSerializer$_setter_$identifier_$eq

protected void akka$serialization$BaseSerializer$_setter_$identifier_$eq(int x$1)

Specified by:

akka$serialization$BaseSerializer$_setter_$identifier_$eq in interface BaseSerializer

atLeastOnceDeliverySnapshot

public AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot atLeastOnceDeliverySnapshot(MessageFormats.AtLeastOnceDeliverySnapshot atLeastOnceDeliverySnapshot)

atLeastOnceDeliverySnapshotBuilder

public MessageFormats.AtLeastOnceDeliverySnapshot.Builder atLeastOnceDeliverySnapshotBuilder(AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot snap)

fromBinary

public Message fromBinary(byte[] bytes,
                          scala.Option<java.lang.Class<?>> manifest)

Deserializes persistent messages. Delegates deserialization of a persistent message's payload to a matching akka.serialization.Serializer.

Specified by:

fromBinary in interface Serializer

Parameters:

bytes - (undocumented)

manifest - (undocumented)

Returns:

(undocumented)

identifier

public int identifier()

Description copied from interface: BaseSerializer

Globally unique serialization identifier configured in the reference.conf.

See Serializer.identifier().

Specified by:

identifier in interface BaseSerializer

Specified by:

identifier in interface Serializer

Returns:

(undocumented)

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

Returns:

(undocumented)

persistentFSMSnapshot

public PersistentFSM.PersistentFSMSnapshot<java.lang.Object> persistentFSMSnapshot(MessageFormats.PersistentFSMSnapshot persistentFSMSnapshot)

persistentFSMSnapshotBuilder

public MessageFormats.PersistentFSMSnapshot.Builder persistentFSMSnapshotBuilder(PersistentFSM.PersistentFSMSnapshot<java.lang.Object> persistentFSMSnapshot)

stateChange

public PersistentFSM.StateChangeEvent stateChange(MessageFormats.PersistentStateChangeEvent persistentStateChange)

stateChangeBuilder

public MessageFormats.PersistentStateChangeEvent.Builder stateChangeBuilder(PersistentFSM.StateChangeEvent stateChange)

system

public ExtendedActorSystem system()

Description copied from interface: BaseSerializer

Actor system which is required by most serializer implementations.

Specified by:

system in interface BaseSerializer

Returns:

(undocumented)

toBinary

public byte[] toBinary(java.lang.Object o)

Serializes persistent messages. Delegates serialization of a persistent message's payload to a matching akka.serialization.Serializer.

Specified by:

toBinary in interface Serializer

Parameters:

o - (undocumented)

Returns:

(undocumented)