Packages

c

akka.persistence.jdbc.journal.dao.legacy

ByteArrayJournalSerializer

class ByteArrayJournalSerializer extends FlowPersistentReprSerializer[JournalRow]

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ByteArrayJournalSerializer
  2. FlowPersistentReprSerializer
  3. PersistentReprSerializer
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new ByteArrayJournalSerializer(serialization: Serialization, separator: String)

Value Members

  1. def deserialize(journalRow: JournalRow): 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
    ByteArrayJournalSerializer → PersistentReprSerializer
  2. def deserializeFlow: Flow[JournalRow, 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

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

    Definition Classes
    FlowPersistentReprSerializer
  3. def serialize(persistentRepr: PersistentRepr, tags: Set[String]): Try[JournalRow]
    Definition Classes
    ByteArrayJournalSerializer → PersistentReprSerializer
  4. def serialize(persistentRepr: PersistentRepr): Try[JournalRow]
    Definition Classes
    PersistentReprSerializer
  5. def serialize(messages: Seq[AtomicWrite]): Seq[Try[Seq[JournalRow]]]

    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