final case class SequencedMessage[A](producerId: String, seqNr: SeqNr, message: MessageOrChunk, first: Boolean, ack: Boolean)(producerController: ActorRef[InternalCommand]) extends Command[A] with DeliverySerializable with DeadLetterSuppression with Product with Serializable

This is used between the ProducerController and ConsumerController. Should rarely be used in application code but is public because it's in the signature for the EntityTypeKey when using ShardingConsumerController.

In the future we may also make the custom send in ProducerController public to make it possible to wrap it or send it in other ways when building higher level abstractions that are using the ProducerController. That is used by ShardingProducerController.

producerController

INTERNAL API: construction of SequencedMessage is internal

Source
ConsumerController.scala
Linear Supertypes
Serializable, Product, Equals, DeadLetterSuppression, DeliverySerializable, Command[A], UnsealedInternalCommand, InternalCommand, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SequencedMessage
  2. Serializable
  3. Product
  4. Equals
  5. DeadLetterSuppression
  6. DeliverySerializable
  7. Command
  8. UnsealedInternalCommand
  9. InternalCommand
  10. AnyRef
  11. 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 SequencedMessage(producerId: String, seqNr: SeqNr, message: MessageOrChunk, first: Boolean, ack: Boolean)(producerController: [InternalCommand])

    producerController

    INTERNAL API: construction of SequencedMessage is internal

Value Members

  1. val ack: Boolean
  2. val first: Boolean
  3. val message: MessageOrChunk
  4. val producerId: String
  5. def productElementNames: Iterator[String]
    Definition Classes
    Product
  6. val seqNr: SeqNr