Package org.apache.pekko.persistence.typed.internal

Class ReplayingSnapshot$

java.lang.Object

org.apache.pekko.persistence.typed.internal.ReplayingSnapshot$

public class ReplayingSnapshot$
extends Object

INTERNAL API

Second (of four) behavior of an EventSourcedBehavior.

In this behavior the recovery process is initiated. We try to obtain a snapshot from the configured snapshot store, and if it exists, we use it instead of the initial emptyState.

Once snapshot recovery is done (or no snapshot was selected), recovery of events continues in ReplayingEvents.

See next behavior ReplayingEvents. See previous behavior RequestingRecoveryPermit.

Field Summary

Fields

Modifier and Type	Field	Description
static final ReplayingSnapshot$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
ReplayingSnapshot$()

Method Summary

Modifier and Type	Method	Description
<C, E, S> Behavior<InternalProtocol>	apply(org.apache.pekko.persistence.typed.internal.BehaviorSetup<C,E,S> setup, boolean receivedPoisonPill)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

MODULE$

public static final ReplayingSnapshot$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

ReplayingSnapshot$

public ReplayingSnapshot$()

Method Details

apply

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