Class DurableProducerQueue$

java.lang.Object
org.apache.pekko.actor.typed.delivery.DurableProducerQueue$

public class DurableProducerQueue$ extends Object
Actor message protocol for storing and confirming reliable delivery of messages. A pekko.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 org.apache.pekko.persistence.typed.delivery.EventSourcedProducerQueue.

  • Field Details

    • MODULE$

      public static final DurableProducerQueue$ MODULE$
      Static reference to the singleton instance of this Scala object.
  • Constructor Details

    • DurableProducerQueue$

      public DurableProducerQueue$()
  • Method Details

    • NoQualifier

      public String NoQualifier()