Class DurableProducerQueue
java.lang.Object
org.apache.pekko.actor.typed.delivery.DurableProducerQueue
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 ClassesModifier and TypeClassDescriptionstatic class
static interface
static class
static interface
INTERNAL APIstatic final class
Request that is used at startup to retrieve the unconfirmed messages and current sequence number.static class
static final class
The fact (event) that a message has been sent.static class
static final class
static class
static final class
Store the fact that a message has been confirmed to be delivered and processed.static class
static final class
Store the fact that a message is to be sent.static class
static final class
static class
-
Constructor Summary
Constructors -
Method Summary
-
Constructor Details
-
DurableProducerQueue
public DurableProducerQueue()
-
-
Method Details
-
NoQualifier
-