final case class State[A](currentSeqNr: SeqNr, highestConfirmedSeqNr: SeqNr, confirmedSeqNr: Map[ConfirmationQualifier, (SeqNr, TimestampMillis)], unconfirmed: IndexedSeq[MessageSent[A]]) extends DeliverySerializable with Product with Serializable

Source
DurableProducerQueue.scala
Linear Supertypes
Serializable, Product, Equals, DeliverySerializable, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. State
  2. Serializable
  3. Product
  4. Equals
  5. DeliverySerializable
  6. AnyRef
  7. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new State(currentSeqNr: SeqNr, highestConfirmedSeqNr: SeqNr, confirmedSeqNr: Map[, (, TimestampMillis)], unconfirmed: [MessageSent[A]])

Value Members

  1. def addMessageSent(sent: MessageSent[A]): State[A]
  2. def cleanup(confirmationQualifiers: Set[String]): State[A]
  3. def cleanupPartialChunkedMessages(): State[A]

    If not all chunked messages were stored before crash those partial chunked messages should not be resent.

  4. def confirmed(seqNr: SeqNr, confirmationQualifier: ConfirmationQualifier, timestampMillis: TimestampMillis): State[A]
  5. val confirmedSeqNr: Map[, (, TimestampMillis)]
  6. val currentSeqNr: SeqNr
  7. val highestConfirmedSeqNr: SeqNr
  8. def productElementNames: Iterator[String]
    Definition Classes
    Product
  9. val unconfirmed: [MessageSent[A]]