Class DurableStateBehavior$

java.lang.Object
org.apache.pekko.persistence.typed.state.scaladsl.DurableStateBehavior$

public class DurableStateBehavior$ extends Object
API May Change
  • Field Details

    • MODULE$

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

    • DurableStateBehavior$

      public DurableStateBehavior$()
  • Method Details

    • apply

      public <Command, State> DurableStateBehavior<Command,State> apply(PersistenceId persistenceId, State emptyState, scala.Function2<State,Command,Effect<State>> commandHandler)
      Create a Behavior for a persistent actor with durable storage of its state.

      Parameters:
      persistenceId - stable unique identifier for the DurableStateBehavior
      emptyState - the initial state for the entity before any state has been stored
      commandHandler - map commands to effects e.g. persisting state, replying to commands
    • withEnforcedReplies

      public <Command, State> DurableStateBehavior<Command,State> withEnforcedReplies(PersistenceId persistenceId, State emptyState, scala.Function2<State,Command,ReplyEffect<State>> commandHandler)
      Create a Behavior for a persistent actor that is enforcing that replies to commands are not forgotten. Then there will be compilation errors if the returned effect isn't a ReplyEffect, which can be created with Effect.reply, Effect.noReply, EffectBuilder.thenReply, or EffectBuilder.thenNoReply.
    • lastSequenceNumber

      public long lastSequenceNumber(ActorContext<?> context)
      The last sequence number that was persisted, can only be called from inside the handlers of a DurableStateBehavior