Namespace Akka.Delivery

Acknowledgement of a message that was received by the consumer, sent to the ConsumerController.

Deliver all buffered messages to consumer then shutdown.

Sent from the consumer controller to the consumer.

Instructs the Akka.Delivery.Internal.ConsumerController`1 to register itself with the Akka.Delivery.Internal.ProducerController`1.

ConsumerController settings.

Used to signal to the ConsumerController that we're ready to start message production.

Durable producer queue state

Request used at startup to retrieve the unconfirmed messages and current sequence number.

Store the fact that a message has been delivered and processed.

Store the fact that a message is to be sent. Replies with StoreMessageSentAck when the message has been successfully stored.

The fact that a message has been sent.

For sending with confirmation back to the producer - message is confirmed once it's stored inside the durable queue.

Registers a ConsumerController with a ProducerController.

A send instruction sent from the ProducerController to the Producer to request the next message to be sent.

Signal to the ProducerController that we're ready to begin message production.

Commands that are specific to the consumer side of the reliable delivery pattern.

Marker interface for all commands handled by the durable producer queue.

Commands that are specific to the producer side of the reliable delivery pattern.