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.

  • Constructor Details

    • DurableProducerQueue

      public DurableProducerQueue()
  • Method Details

    • NoQualifier

      public static String NoQualifier()