akka.persistence

stream

package stream

Visibility
  1. Public
  2. All

Type Members

  1. case class PersistentPublisherSettings(fromSequenceNr: Long = 1L, maxBufferSize: Int = 100, idle: Option[FiniteDuration] = None) extends Product with Serializable

    Configuration object for a akka.persistence.Persistent stream publisher.

    Configuration object for a akka.persistence.Persistent stream publisher.

    fromSequenceNr

    Sequence number where the published stream shall start (inclusive). Default is 1L.

    maxBufferSize

    Maximum number of persistent messages to be buffered in memory (per publisher). Default is 100.

    idle

    Optional duration to wait if no more persistent messages can be pulled from the journal before attempting the next pull. Default is None which causes the publisher to take the value defined by the akka.persistence.view.auto-update-interval configuration key. If defined, the idle value is taken directly.

Value Members

  1. object PersistentFlow

Ungrouped