final case class RequestNext[A](producerId: String, currentSeqNr: SeqNr, confirmedSeqNr: SeqNr, sendNextTo: ActorRef[A], askNextTo: ActorRef[MessageWithConfirmation[A]]) extends Product with Serializable

The ProducerController sends RequestNext to the producer when it is allowed to send one message via the sendNextTo or askNextTo. Note that only one message is allowed, and then it must wait for next RequestNext before sending one more message.

Source
ProducerController.scala
Linear Supertypes
Serializable, Product, Equals, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. RequestNext
  2. Serializable
  3. Product
  4. Equals
  5. AnyRef
  6. 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 RequestNext(producerId: String, currentSeqNr: SeqNr, confirmedSeqNr: SeqNr, sendNextTo: ActorRef[A], askNextTo: [MessageWithConfirmation[A]])

Value Members

  1. val askNextTo: [MessageWithConfirmation[A]]
  2. val confirmedSeqNr: SeqNr
  3. val currentSeqNr: SeqNr
  4. val producerId: String
  5. def productElementNames: Iterator[String]
    Definition Classes
    Product
  6. val sendNextTo: ActorRef[A]