Class BehaviorSetup<C,​E,​S>


  • public final class BehaviorSetup<C,​E,​S>
    extends java.lang.Object
    INTERNAL API: Carry state for the Persistent behavior implementation behaviors.
    • Method Detail

      • cancelRecoveryTimer

        public void cancelRecoveryTimer()
      • commandHandler

        public scala.Function2<S,​C,​Effect<E,​S>> commandHandler()
      • emptyState

        public S emptyState()
      • eventHandler

        public scala.Function2<S,​E,​S> eventHandler()
      • holdingRecoveryPermit

        public boolean holdingRecoveryPermit()
      • holdingRecoveryPermit_$eq

        public void holdingRecoveryPermit_$eq​(boolean x$1)
      • onRecoveryFailure

        public scala.Function1<java.lang.Throwable,​scala.runtime.BoxedUnit> onRecoveryFailure()
      • onSnapshot

        public scala.Function2<SnapshotMetadata,​scala.util.Try<Done>,​scala.runtime.BoxedUnit> onSnapshot()
      • recoveryCompleted

        public scala.Function1<S,​scala.runtime.BoxedUnit> recoveryCompleted()
      • selfUntyped

        public ActorRef selfUntyped()
      • setMdc

        public BehaviorSetup<C,​E,​S> setMdc​(scala.collection.immutable.Map<java.lang.String,​java.lang.Object> newMdc)
      • setMdc

        public BehaviorSetup<C,​E,​S> setMdc​(java.lang.String phaseName)
      • snapshotStore

        public ActorRef snapshotStore()
      • snapshotWhen

        public scala.Function3<S,​E,​java.lang.Object,​java.lang.Object> snapshotWhen()
      • startRecoveryTimer

        public void startRecoveryTimer​(boolean snapshot)
      • tagger

        public scala.Function1<E,​scala.collection.immutable.Set<java.lang.String>> tagger()