Packages

class MessageSerializer extends BaseSerializer

Protobuf serializer for akka.persistence.PersistentRepr, akka.persistence.AtLeastOnceDelivery and akka.persistence.fsm.PersistentFSM.StateChangeEvent messages.

Annotations
@ccompatUsedUntil213()
Source
MessageSerializer.scala
Linear Supertypes
BaseSerializer, Serializer, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MessageSerializer
  2. BaseSerializer
  3. Serializer
  4. AnyRef
  5. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new MessageSerializer(system: ExtendedActorSystem)

Value Members

  1. val AtLeastOnceDeliverySnapshotClass: Class[AtLeastOnceDeliverySnapshot]
  2. val AtomicWriteClass: Class[AtomicWrite]
  3. val PersistentFSMSnapshotClass: Class[PersistentFSMSnapshot[Any]]
  4. val PersistentImplClass: Class[PersistentImpl]
  5. val PersistentReprClass: Class[PersistentRepr]
  6. val PersistentStateChangeEventClass: Class[StateChangeEvent]
  7. final val SerializationIdentifiers: String("akka.actor.serialization-identifiers")

    Configuration namespace of serialization identifiers in the reference.conf.

    Configuration namespace of serialization identifiers in the reference.conf.

    Each serializer implementation must have an entry in the following format: akka.actor.serialization-identifiers."FQCN" = ID where FQCN is fully qualified class name of the serializer implementation and ID is globally unique serializer identifier number.

    Definition Classes
    BaseSerializer
  8. def atLeastOnceDeliverySnapshot(atLeastOnceDeliverySnapshot: AtLeastOnceDeliverySnapshot): AtLeastOnceDeliverySnapshot
  9. def atLeastOnceDeliverySnapshotBuilder(snap: AtLeastOnceDeliverySnapshot): Builder
  10. def fromBinary(bytes: Array[Byte], manifest: Option[Class[_]]): Message

    Deserializes persistent messages.

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

    Definition Classes
    MessageSerializer → Serializer
  11. final def fromBinary(bytes: Array[Byte], clazz: Class[_]): AnyRef

    Java API: deserialize with type hint

    Java API: deserialize with type hint

    Definition Classes
    Serializer
    Annotations
    @throws(classOf[NotSerializableException])
  12. final def fromBinary(bytes: Array[Byte]): AnyRef

    Java API: deserialize without type hint

    Java API: deserialize without type hint

    Definition Classes
    Serializer
  13. val identifier: Int

    Globally unique serialization identifier configured in the reference.conf.

    Globally unique serialization identifier configured in the reference.conf.

    See Serializer.identifier.

    Definition Classes
    BaseSerializer → Serializer
  14. val includeManifest: Boolean

    Returns whether this serializer needs a manifest in the fromBinary method

    Returns whether this serializer needs a manifest in the fromBinary method

    Definition Classes
    MessageSerializer → Serializer
  15. def persistentFSMSnapshot(persistentFSMSnapshot: PersistentFSMSnapshot): PersistentFSMSnapshot[Any]
  16. def stateChange(persistentStateChange: PersistentStateChangeEvent): StateChangeEvent
    Annotations
    @nowarn()
  17. val system: ExtendedActorSystem

    Actor system which is required by most serializer implementations.

    Actor system which is required by most serializer implementations.

    Definition Classes
    MessageSerializer → BaseSerializer
  18. def toBinary(o: AnyRef): Array[Byte]

    Serializes persistent messages.

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

    Definition Classes
    MessageSerializer → Serializer