Packages

t

akka.persistence.jdbc.serialization

FlowPersistentReprSerializer

trait FlowPersistentReprSerializer[T] extends PersistentReprSerializer[T]

Annotations
@deprecated
Deprecated

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

Source
PersistentReprSerializer.scala
Linear Supertypes
PersistentReprSerializer[T], AnyRef, Any
Known Subclasses
ByteArrayJournalSerializer
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. FlowPersistentReprSerializer
  2. PersistentReprSerializer
  3. AnyRef
  4. 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

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

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

Concrete Value Members

  1. def deserializeFlow: Flow[T, Try[(PersistentRepr, Set[String], Long)], NotUsed]

    A flow which deserializes each element into a PersistentRepr, a set of tags and a Long representing the global ordering of events

  2. def serialize(persistentRepr: PersistentRepr): Try[T]
    Definition Classes
    PersistentReprSerializer
  3. 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.

    Definition Classes
    PersistentReprSerializer