Package akka.persistence.fsm

Interface PersistentFSM<S extends PersistentFSM.FSMState,​D,​E>

    • Method Detail

      • akka$persistence$fsm$PersistentFSM$_setter_$domainEventTag_$eq

        void akka$persistence$fsm$PersistentFSM$_setter_$domainEventTag_$eq​(scala.reflect.ClassTag<E> x$1)
        Domain event's ClassTag Used for identifying domain events during recovery
        Parameters:
        x$1 - (undocumented)

      • super$applyState

        void super$applyState​(PersistentFSM.State<S,​D,​E> nextState)
        Persist FSM State and FSM State Data
        Parameters:
        nextState - (undocumented)

      • domainEventClassTag

        scala.reflect.ClassTag<E> domainEventClassTag()
        Enables to pass a ClassTag of a domain event base type from the implementing class

        Returns:
        ClassTag of domain event base type

      • domainEventTag

        scala.reflect.ClassTag<E> domainEventTag()
        Domain event's ClassTag Used for identifying domain events during recovery
        Returns:
        (undocumented)

      • statesMap

        scala.collection.immutable.Map<java.lang.String,​S> statesMap()
        Map from state identifier to state instance
        Returns:
        (undocumented)

      • currentStateTimeout_$eq

        void currentStateTimeout_$eq​(scala.Option<scala.concurrent.duration.FiniteDuration> x$1)

      • applyEvent

        D applyEvent​(E domainEvent,
             D currentData)
        Override this handler to define the action on Domain Event

        Parameters:
        domainEvent - domain event to apply
        currentData - state data of the previous state
        Returns:
        updated state data

      • onRecoveryCompleted

        void onRecoveryCompleted()
        Override this handler to define the action on recovery completion

      • saveStateSnapshot

        void saveStateSnapshot()
        Save the current state as a snapshot

      • receiveCommand

        scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receiveCommand()
        After recovery events are handled as in usual FSM actor
        Specified by:
        receiveCommand in interface Eventsourced
        Returns:
        (undocumented)

      • receiveRecover

        scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receiveRecover()
        Discover the latest recorded state
        Specified by:
        receiveRecover in interface Eventsourced
        Returns:
        (undocumented)
        See Also:
        Recovery