akka.persistence.serialization
Class MessageSerializer

java.lang.Object
  extended by akka.persistence.serialization.MessageSerializer
All Implemented Interfaces:
Serializer

public class MessageSerializer
extends java.lang.Object
implements Serializer

Protobuf serializer for PersistentBatch, PersistentRepr and Deliver messages.


Constructor Summary
MessageSerializer(ExtendedActorSystem system)
           
 
Method Summary
 AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot atLeastOnceDeliverySnapshot(MessageFormats.AtLeastOnceDeliverySnapshot atLeastOnceDeliverySnapshot)
           
 MessageFormats.AtLeastOnceDeliverySnapshot.Builder atLeastOnceDeliverySnapshotBuilder(AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot snap)
           
 java.lang.Class<AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot> AtLeastOnceDeliverySnapshotClass()
           
 java.lang.Class<ConfirmablePersistentImpl> ConfirmablePersistentImplClass()
           
 java.lang.Class<Deliver> DeliverClass()
           
 java.lang.Class<DeliveredByPersistentChannel> DeliveredByPersistentChannelClass()
           
 java.lang.Class<DeliveredByChannel> DeliveredByTransientChannelClass()
           
 Message fromBinary(byte[] bytes, scala.Option<java.lang.Class<?>> manifest)
          Deserializes PersistentBatch, PersistentRepr and Deliver messages.
 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
 java.lang.Class<PersistentBatch> PersistentBatchClass()
           
 java.lang.Class<PersistentImpl> PersistentImplClass()
           
 java.lang.Class<PersistentRepr> PersistentReprClass()
           
 ExtendedActorSystem system()
           
 byte[] toBinary(java.lang.Object o)
          Serializes PersistentBatch, PersistentRepr and Deliver 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.Serializer
fromBinary, fromBinary
 

Constructor Detail

MessageSerializer

public MessageSerializer(ExtendedActorSystem system)
Method Detail

system

public ExtendedActorSystem system()

PersistentBatchClass

public java.lang.Class<PersistentBatch> PersistentBatchClass()

PersistentReprClass

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

PersistentImplClass

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

ConfirmablePersistentImplClass

public java.lang.Class<ConfirmablePersistentImpl> ConfirmablePersistentImplClass()

DeliveredByTransientChannelClass

public java.lang.Class<DeliveredByChannel> DeliveredByTransientChannelClass()

DeliveredByPersistentChannelClass

public java.lang.Class<DeliveredByPersistentChannel> DeliveredByPersistentChannelClass()

DeliverClass

public java.lang.Class<Deliver> DeliverClass()

AtLeastOnceDeliverySnapshotClass

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

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
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)

toBinary

public byte[] toBinary(java.lang.Object o)
Serializes PersistentBatch, PersistentRepr and Deliver 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)

fromBinary

public Message fromBinary(byte[] bytes,
                          scala.Option<java.lang.Class<?>> manifest)
Deserializes PersistentBatch, PersistentRepr and Deliver 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)

atLeastOnceDeliverySnapshotBuilder

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

atLeastOnceDeliverySnapshot

public AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot atLeastOnceDeliverySnapshot(MessageFormats.AtLeastOnceDeliverySnapshot atLeastOnceDeliverySnapshot)