Packages

o

akka.actor.typed.delivery

DurableProducerQueue

object DurableProducerQueue

Actor message protocol for storing and confirming reliable delivery of messages. A akka.actor.typed.Behavior implementation of this protocol can optionally be used with ProducerController when messages shall survive a crash of the producer side.

An implementation of this exists in akka.persistence.typed.delivery.EventSourcedProducerQueue.

Annotations
@ApiMayChange()
Source
DurableProducerQueue.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DurableProducerQueue
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. trait Command[A] extends AnyRef
  2. type ConfirmationQualifier = String
  3. final case class LoadState[A](replyTo: ActorRef[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 case class MessageSent[A](seqNr: SeqNr, message: A, ack: Boolean, confirmationQualifier: ConfirmationQualifier, timestampMillis: TimestampMillis) extends Event with Product with Serializable

    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[ConfirmationQualifier, (SeqNr, TimestampMillis)], unconfirmed: IndexedSeq[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: ActorRef[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

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. val NoQualifier: ConfirmationQualifier
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @HotSpotIntrinsicCandidate()
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  9. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  11. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  12. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  14. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  15. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  16. def toString(): String
    Definition Classes
    AnyRef → Any
  17. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  18. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  19. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  20. object State extends Serializable

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] ) @Deprecated @deprecated
    Deprecated

    (Since version ) see corresponding Javadoc for more information.

Inherited from AnyRef

Inherited from Any

Ungrouped