Packages

t

akka.persistence.jdbc.serialization

PersistentReprSerializer

trait PersistentReprSerializer[T] extends AnyRef

Annotations
@deprecated
Deprecated

(Since version 5.0.0) use Akka Serialization for the payloads instead

Source
PersistentReprSerializer.scala
Linear Supertypes
AnyRef, Any
Known Subclasses
ByteArrayJournalSerializer, FlowPersistentReprSerializer
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PersistentReprSerializer
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def deserialize(t: T): Try[(PersistentRepr, Set[String], Long)]

    deserialize into a PersistentRepr, a set of tags and a Long representing the global ordering of events

  2. abstract def serialize(persistentRepr: PersistentRepr, tags: Set[String]): Try[T]

Concrete Value Members

  1. def serialize(persistentRepr: PersistentRepr): Try[T]
  2. def serialize(messages: Seq[AtomicWrite]): Seq[Try[Seq[T]]]

    An akka.persistence.AtomicWrite contains a Sequence of events (with metadata, the PersistentRepr) that must all be persisted or all fail, what makes the operation atomic.

    An akka.persistence.AtomicWrite contains a Sequence of events (with metadata, the PersistentRepr) that must all be persisted or all fail, what makes the operation atomic. The function converts each AtomicWrite to a Try[Seq[T]]. The Try denotes whether there was a problem with the AtomicWrite or not.