Class RequestingRecoveryPermit$

java.lang.Object
org.apache.pekko.persistence.typed.internal.RequestingRecoveryPermit$

public class RequestingRecoveryPermit$ extends Object
INTERNAL API

First (of four) behavior of an PersistentBehaviour.

Requests a permit to start replaying this actor; this is tone to avoid hammering the journal with too many concurrently replaying actors.

See next behavior ReplayingSnapshot.

  • Field Details

    • MODULE$

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

    • RequestingRecoveryPermit$

      public RequestingRecoveryPermit$()
  • Method Details

    • apply

      public <C, E, S> Behavior<InternalProtocol> apply(org.apache.pekko.persistence.typed.internal.BehaviorSetup<C,E,S> setup)