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

Class Running$

java.lang.Object
org.apache.pekko.persistence.typed.internal.Running$
public class Running$ extends Object
INTERNAL API

Conceptually fourth (of four) -- also known as 'final' or 'ultimate' -- form of EventSourcedBehavior.

In this phase recovery has completed successfully and we continue handling incoming commands, as well as persisting new events as dictated by the user handlers.

This behavior operates in three phases (also behaviors): - HandlingCommands - where the command handler is invoked for incoming commands - PersistingEvents - where incoming commands are stashed until persistence completes - storingSnapshot - where incoming commands are stashed until snapshot storage completes

This is implemented as such to avoid creating many EventSourced Running instances, which perform the Persistence extension lookup on creation and similar things (config lookup)

See previous ReplayingEvents.

  • Field Summary

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

  • Constructor Summary

    Constructors
    Constructor
    Description
    Running$()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    String
    formatTimestamp(long time)
     
    <C, E, S> org.apache.pekko.persistence.typed.internal.Running.RunningState<S,C>
    startReplicationStream(org.apache.pekko.persistence.typed.internal.BehaviorSetup<C,E,S> setup, org.apache.pekko.persistence.typed.internal.Running.RunningState<S,C> state, org.apache.pekko.persistence.typed.internal.ReplicationSetup replicationSetup)
     

    Methods inherited from class java.lang.Object

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

  • Field Details

    • MODULE$

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

  • Constructor Details

    • Running$

      public Running$()

  • Method Details

    • startReplicationStream

      public <C, E, S> org.apache.pekko.persistence.typed.internal.Running.RunningState<S,C> startReplicationStream(org.apache.pekko.persistence.typed.internal.BehaviorSetup<C,E,S> setup, org.apache.pekko.persistence.typed.internal.Running.RunningState<S,C> state, org.apache.pekko.persistence.typed.internal.ReplicationSetup replicationSetup)

    • formatTimestamp

      public String formatTimestamp(long time)