Package org.apache.pekko.persistence.typed.delivery

Class EventSourcedProducerQueue$

java.lang.Object

org.apache.pekko.persistence.typed.delivery.EventSourcedProducerQueue$

public class EventSourcedProducerQueue$
extends Object

pekko.actor.typed.delivery.DurableProducerQueue that can be used with pekko.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.

Field Summary

Fields

Modifier and Type	Field	Description
static final EventSourcedProducerQueue$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
EventSourcedProducerQueue$()

Method Summary

Modifier and Type	Method	Description
<A> Behavior<DurableProducerQueue.Command<A>>	apply(PersistenceId persistenceId)
<A> Behavior<DurableProducerQueue.Command<A>>	apply(PersistenceId persistenceId, EventSourcedProducerQueue.Settings settings)
<A> Behavior<DurableProducerQueue.Command<A>>	create(PersistenceId persistenceId)	Java API
<A> Behavior<DurableProducerQueue.Command<A>>	create(PersistenceId persistenceId, EventSourcedProducerQueue.Settings settings)	Java API

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MODULE$

public static final EventSourcedProducerQueue$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

EventSourcedProducerQueue$

public EventSourcedProducerQueue$()

Method Details

apply

public <A>
Behavior<DurableProducerQueue.Command<A>> apply(PersistenceId persistenceId)

apply

public <A>
Behavior<DurableProducerQueue.Command<A>> apply(PersistenceId persistenceId,
 EventSourcedProducerQueue.Settings settings)

create

public <A>
Behavior<DurableProducerQueue.Command<A>> create(PersistenceId persistenceId)

Java API

create

public <A>
Behavior<DurableProducerQueue.Command<A>> create(PersistenceId persistenceId,
 EventSourcedProducerQueue.Settings settings)

Java API