Package akka.persistence.typed.internal

Class ReplayingEvents$

  • public class ReplayingEvents$
extends java.lang.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 ReplayingEvents$ MODULE$
      Static reference to the singleton instance of this Scala object.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <C,​E,​S>
      Behavior<InternalProtocol>      		 apply​(akka.persistence.typed.internal.BehaviorSetup<C,​E,​S> setup, akka.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 Detail

      • MODULE$

        public static final ReplayingEvents$ MODULE$
        Static reference to the singleton instance of this Scala object.

    • Constructor Detail

      • ReplayingEvents$

        public ReplayingEvents$()

    • Method Detail

      • apply

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