|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.persistence.serialization.MessageSerializer
public class MessageSerializer
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 |
---|
public MessageSerializer(ExtendedActorSystem system)
Method Detail |
---|
public ExtendedActorSystem system()
public java.lang.Class<PersistentBatch> PersistentBatchClass()
public java.lang.Class<PersistentRepr> PersistentReprClass()
public java.lang.Class<PersistentImpl> PersistentImplClass()
public java.lang.Class<ConfirmablePersistentImpl> ConfirmablePersistentImplClass()
public java.lang.Class<DeliveredByChannel> DeliveredByTransientChannelClass()
public java.lang.Class<DeliveredByPersistentChannel> DeliveredByPersistentChannelClass()
public java.lang.Class<Deliver> DeliverClass()
public java.lang.Class<AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot> AtLeastOnceDeliverySnapshotClass()
public int identifier()
Serializer
identifier
in interface Serializer
public boolean includeManifest()
Serializer
includeManifest
in interface Serializer
public byte[] toBinary(java.lang.Object o)
PersistentBatch
, PersistentRepr
and Deliver
messages. Delegates
serialization of a persistent message's payload to a matching akka.serialization.Serializer
.
toBinary
in interface Serializer
o
- (undocumented)
public Message fromBinary(byte[] bytes, scala.Option<java.lang.Class<?>> manifest)
PersistentBatch
, PersistentRepr
and Deliver
messages. Delegates
deserialization of a persistent message's payload to a matching akka.serialization.Serializer
.
fromBinary
in interface Serializer
bytes
- (undocumented)manifest
- (undocumented)
public MessageFormats.AtLeastOnceDeliverySnapshot.Builder atLeastOnceDeliverySnapshotBuilder(AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot snap)
public AtLeastOnceDelivery.AtLeastOnceDeliverySnapshot atLeastOnceDeliverySnapshot(MessageFormats.AtLeastOnceDeliverySnapshot atLeastOnceDeliverySnapshot)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |