akka.persistence.multidc.serialization

Class ReplicatedEntitySerializer

java.lang.Object

akka.serialization.SerializerWithStringManifest

akka.persistence.multidc.serialization.ReplicatedEntitySerializer

All Implemented Interfaces:

akka.serialization.BaseSerializer, akka.serialization.Serializer

public class ReplicatedEntitySerializer
extends akka.serialization.SerializerWithStringManifest
implements akka.serialization.BaseSerializer

INTERNAL API: Protobuf serializer of replicated entity messages/data.

Constructor Summary

Constructors

Constructor and Description
ReplicatedEntitySerializer(akka.actor.ExtendedActorSystem system)

Method Summary

Modifier and Type	Method and Description
protected void	akka$serialization$BaseSerializer$_setter_$identifier_$eq(int x$1)
java.lang.Object	fromBinary(byte[] bytes, java.lang.String manifest)
int	identifier()
java.lang.String	manifest(java.lang.Object obj)
ReplicatedEntityActor.ReplicatedEventMetaData	metaDataFromBinary(byte[] bytes)
ReplicatedEntityActor.ReplicatedEventMetaData	metaDataFromProto(ReplicatedEvents.ReplicatedEventMetaData metaData)
ReplicatedEvents.ReplicatedEventMetaData.Builder	metaDataToProto(ReplicatedEntityActor.ReplicatedEventMetaData metaData)
NotificationWriter.Notification	notificationFromBinary(byte[] bytes)
NotificationWriter.Notification	notificationFromProto(ReplicatedEvents.Notification notification)
java.lang.String	NotificationManifest()
ReplicatedEvents.Notification.Builder	notificationToProto(NotificationWriter.Notification notification)
java.lang.String	ReplicatedEntitySnapshotManifest()
java.lang.String	ReplicatedEventMetaDataManifest()
byte[]	speculativeReplicatedEventAckToProtoByteArray(ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl speculative)
SpeculativeReplicatedEvent	speculativeReplicatedEventFromBinary(byte[] bytes)
java.lang.String	SpeculativeReplicatedEventManifest()
byte[]	speculativeReplicatedEventToProtoByteArray(ReplicatedEntityActor.SpeculativeReplicatedEventImpl<?> speculative)
akka.actor.ExtendedActorSystem	system()
byte[]	toBinary(java.lang.Object obj)

Methods inherited from class akka.serialization.SerializerWithStringManifest

fromBinary, fromBinary, fromBinary, includeManifest

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

$init$, identifierFromConfig, SerializationIdentifiers

Methods inherited from interface akka.serialization.Serializer

$init$, fromBinary, fromBinary, fromBinary, includeManifest

Constructor Detail

ReplicatedEntitySerializer

public ReplicatedEntitySerializer(akka.actor.ExtendedActorSystem system)

Method Detail

NotificationManifest

public java.lang.String NotificationManifest()

ReplicatedEntitySnapshotManifest

public java.lang.String ReplicatedEntitySnapshotManifest()

ReplicatedEventMetaDataManifest

public java.lang.String ReplicatedEventMetaDataManifest()

SpeculativeReplicatedEventManifest

public java.lang.String SpeculativeReplicatedEventManifest()

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 akka.serialization.BaseSerializer

fromBinary

public java.lang.Object fromBinary(byte[] bytes,
                                   java.lang.String manifest)

Specified by:

fromBinary in class akka.serialization.SerializerWithStringManifest

identifier

public int identifier()

Specified by:

identifier in interface akka.serialization.BaseSerializer

Specified by:

identifier in interface akka.serialization.Serializer

Specified by:

identifier in class akka.serialization.SerializerWithStringManifest

manifest

public java.lang.String manifest(java.lang.Object obj)

Specified by:

manifest in class akka.serialization.SerializerWithStringManifest

metaDataFromBinary

public ReplicatedEntityActor.ReplicatedEventMetaData metaDataFromBinary(byte[] bytes)

metaDataFromProto

public ReplicatedEntityActor.ReplicatedEventMetaData metaDataFromProto(ReplicatedEvents.ReplicatedEventMetaData metaData)

metaDataToProto

public ReplicatedEvents.ReplicatedEventMetaData.Builder metaDataToProto(ReplicatedEntityActor.ReplicatedEventMetaData metaData)

notificationFromBinary

public NotificationWriter.Notification notificationFromBinary(byte[] bytes)

notificationFromProto

public NotificationWriter.Notification notificationFromProto(ReplicatedEvents.Notification notification)

notificationToProto

public ReplicatedEvents.Notification.Builder notificationToProto(NotificationWriter.Notification notification)

speculativeReplicatedEventAckToProtoByteArray

public byte[] speculativeReplicatedEventAckToProtoByteArray(ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl speculative)

speculativeReplicatedEventFromBinary

public SpeculativeReplicatedEvent speculativeReplicatedEventFromBinary(byte[] bytes)

speculativeReplicatedEventToProtoByteArray

public byte[] speculativeReplicatedEventToProtoByteArray(ReplicatedEntityActor.SpeculativeReplicatedEventImpl<?> speculative)

system

public akka.actor.ExtendedActorSystem system()

Specified by:

system in interface akka.serialization.BaseSerializer

toBinary

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

Specified by:

toBinary in interface akka.serialization.Serializer

Specified by:

toBinary in class akka.serialization.SerializerWithStringManifest