Package akka.actor.typed.delivery
Class DurableProducerQueue
- java.lang.Object
-
- akka.actor.typed.delivery.DurableProducerQueue
-
public class DurableProducerQueue extends java.lang.ObjectActor message protocol for storing and confirming reliable delivery of messages. ABehaviorimplementation of this protocol can optionally be used withProducerControllerwhen messages shall survive a crash of the producer side.An implementation of this exists in
akka.persistence.typed.delivery.EventSourcedProducerQueue.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classDurableProducerQueue.Cleanup$static interfaceDurableProducerQueue.Command<A>static classDurableProducerQueue.Confirmed$static interfaceDurableProducerQueue.EventINTERNAL APIstatic classDurableProducerQueue.LoadState<A>Request that is used at startup to retrieve the unconfirmed messages and current sequence number.static classDurableProducerQueue.LoadState$static classDurableProducerQueue.MessageSent<A>The fact (event) that a message has been sent.static classDurableProducerQueue.MessageSent$static classDurableProducerQueue.State<A>static classDurableProducerQueue.State$static classDurableProducerQueue.StoreMessageConfirmed<A>Store the fact that a message has been confirmed to be delivered and processed.static classDurableProducerQueue.StoreMessageConfirmed$static classDurableProducerQueue.StoreMessageSent<A>Store the fact that a message is to be sent.static classDurableProducerQueue.StoreMessageSent$static classDurableProducerQueue.StoreMessageSentAckstatic classDurableProducerQueue.StoreMessageSentAck$
-
Constructor Summary
Constructors Constructor Description DurableProducerQueue()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static java.lang.StringNoQualifier()
-