Package org.apache.pekko.actor.typed.delivery

Class DurableProducerQueue

java.lang.Object

org.apache.pekko.actor.typed.delivery.DurableProducerQueue

public class DurableProducerQueue
extends Object

Actor message protocol for storing and confirming reliable delivery of messages. A pekko.actor.typed.Behavior implementation of this protocol can optionally be used with ProducerController when messages shall survive a crash of the producer side.

An implementation of this exists in org.apache.pekko.persistence.typed.delivery.EventSourcedProducerQueue.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DurableProducerQueue.Cleanup$
static interface	DurableProducerQueue.Command<A>
static class	DurableProducerQueue.Confirmed$
static interface	DurableProducerQueue.Event	INTERNAL API
static final class	DurableProducerQueue.LoadState<A>	Request that is used at startup to retrieve the unconfirmed messages and current sequence number.
static class	DurableProducerQueue.LoadState$
static final class	DurableProducerQueue.MessageSent<A>	The fact (event) that a message has been sent.
static class	DurableProducerQueue.MessageSent$
static final class	DurableProducerQueue.State<A>
static class	DurableProducerQueue.State$
static final class	DurableProducerQueue.StoreMessageConfirmed<A>	Store the fact that a message has been confirmed to be delivered and processed.
static class	DurableProducerQueue.StoreMessageConfirmed$
static final class	DurableProducerQueue.StoreMessageSent<A>	Store the fact that a message is to be sent.
static class	DurableProducerQueue.StoreMessageSent$
static final class	DurableProducerQueue.StoreMessageSentAck
static class	DurableProducerQueue.StoreMessageSentAck$

Constructor Summary

Constructors

Constructor	Description
DurableProducerQueue()

Method Summary

Modifier and Type	Method	Description
static String	NoQualifier()

Methods inherited from class java.lang.Object

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

Constructor Details

DurableProducerQueue

public DurableProducerQueue()

Method Details

NoQualifier

public static String NoQualifier()