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

Class ReplayingEvents$

java.lang.Object

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

public class ReplayingEvents$
extends Object

* INTERNAL API

Third (of four) behavior of an EventSourcedBehavior.

In this behavior we finally start replaying events, beginning from the last applied sequence number (i.e. the one up-until-which the snapshot recovery has brought us).

Once recovery is completed, the actor becomes Running, stashed messages are flushed and control is given to the user's handlers to drive the actors behavior from there.

See next behavior Running. See previous behavior ReplayingSnapshot.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
ReplayingEvents$()

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

MODULE$

public static final ReplayingEvents$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

ReplayingEvents$

public ReplayingEvents$()

Method Details

apply

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