DurableProducerQueue

Type Members

1.  trait Command[A] extends AnyRef
2.  type ConfirmationQualifier = String
3.  final case class LoadState[A](replyTo: [State[A]]) extends Command[A] with Product with Serializable

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

4.  final class MessageSent[A] extends Event

   The fact (event) that a message has been sent.

5.  type SeqNr = Long
6.  final case class State[A](currentSeqNr: SeqNr, highestConfirmedSeqNr: SeqNr, confirmedSeqNr: Map[, (, TimestampMillis)], unconfirmed: [MessageSent[A]]) extends DeliverySerializable with Product with Serializable
7.  final case class StoreMessageConfirmed[A](seqNr: SeqNr, confirmationQualifier: ConfirmationQualifier, timestampMillis: TimestampMillis) extends Command[A] with Product with Serializable

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

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

   This command may be retied and the implementation should be idempotent, i.e. deduplicate already processed sequence numbers.

8.  final case class StoreMessageSent[A](sent: MessageSent[A], replyTo: [StoreMessageSentAck]) extends Command[A] with Product with Serializable

   Store the fact that a message is to be sent.

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

   This command may be retied and the implementation should be idempotent, i.e. deduplicate already processed sequence numbers.

9.  final case class StoreMessageSentAck(storedSeqNr: SeqNr) extends Product with Serializable
10.  type TimestampMillis = Long