o

akka.persistence.typed.delivery

EventSourcedProducerQueue

object EventSourcedProducerQueue

DurableProducerQueue that can be used with akka.actor.typed.delivery.ProducerController for reliable delivery of messages. It is implemented with Event Sourcing and stores one event before sending the message to the destination and one event for the confirmation that the message has been delivered and processed.

The DurableProducerQueue.LoadState request is used at startup to retrieve the unconfirmed messages.

Annotations
@ApiMayChange()
Source
EventSourcedProducerQueue.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. EventSourcedProducerQueue
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. final class Settings extends AnyRef

Value Members

  1. def apply[A](persistenceId: PersistenceId, settings: Settings): [Command[A]]
  2. def apply[A](persistenceId: PersistenceId): [Command[A]]
  3. def create[A](persistenceId: PersistenceId, settings: Settings): [Command[A]]

    Java API

  4. def create[A](persistenceId: PersistenceId): [Command[A]]

    Java API

  5. object Settings