public abstract class AbstractPersistentLoggingFSM<S extends PersistentFSM.FSMState,D,E> extends AbstractPersistentFSMBase<S,D,E> implements LoggingPersistentFSM<S,D,E>, PersistentFSM<S,D,E>
Persistent Finite State Machine actor abstract base class with FSM Logging
This is an EXPERIMENTAL feature and is subject to change until it has received more real world testing.
PersistentFSM.$minus$greater$, PersistentFSM.CurrentState<S>, PersistentFSM.CurrentState$, PersistentFSM.Event<D>, PersistentFSM.Event$, PersistentFSM.Failure, PersistentFSM.Failure$, PersistentFSM.FSMState, PersistentFSM.LogEntry<S,D>, PersistentFSM.LogEntry$, PersistentFSM.Normal$, PersistentFSM.NullFunction$, PersistentFSM.PersistentFsmEvent, PersistentFSM.Reason, PersistentFSM.Shutdown$, PersistentFSM.State<S,D,E>, PersistentFSM.State$, PersistentFSM.StateChangeEvent, PersistentFSM.StateChangeEvent$, PersistentFSM.StateTimeout$, PersistentFSM.StopEvent<S,D>, PersistentFSM.StopEvent$, PersistentFSM.SubscribeTransitionCallBack, PersistentFSM.SubscribeTransitionCallBack$, PersistentFSM.TimeoutMarker, PersistentFSM.TimeoutMarker$, PersistentFSM.Timer, PersistentFSM.Timer$, PersistentFSM.Transition<S>, PersistentFSM.Transition$, PersistentFSM.UnsubscribeTransitionCallBack, PersistentFSM.UnsubscribeTransitionCallBack$
Eventsourced.AsyncHandlerInvocation, Eventsourced.AsyncHandlerInvocation$, Eventsourced.PendingHandlerInvocation, Eventsourced.StashingHandlerInvocation, Eventsourced.StashingHandlerInvocation$
akka.actor.Actor.emptyBehavior$, akka.actor.Actor.ignoringBehavior$
PersistentFSMBase.TransformHelper
Constructor and Description |
---|
AbstractPersistentLoggingFSM() |
goTo, matchAnyEvent, matchData, matchData, matchEvent, matchEvent, matchEvent, matchEvent, matchEvent, matchEvent, matchEvent, matchEventEquals, matchEventEquals, matchState, matchState, matchStop, matchStop, matchStop, Normal, NullFunction, onTermination, onTransition, onTransition, setTimer, Shutdown, startWith, startWith, when, when, when, whenUnhandled
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
advance, debugEvent, events, full, getLog, logDepth, pos, processEvent, states
applyEvent, applyState, domainEventClassTag, domainEventTag, onRecoveryCompleted, receiveCommand, receiveRecover, statesMap
receive
_lastSequenceNr, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, changeState, currentState, deferAsync, deleteMessages, eventBatch, extension, flushBatch, flushJournalBatch, instanceId, internalStash, journal, journalBatch, lastSequenceNr, log, maxMessageBatchSize, nextSequenceNr, onPersistFailure, onPersistRejected, onRecoveryFailure, onReplaySuccess, peekApplyHandler, pendingInvocations, pendingStashingPersistInvocations, persist, persist, persistAll, persistAllAsync, persistAsync, persistAsync, persistingEvents, processingCommands, recovering, recoveryFinished, recoveryRunning, recoveryStarted, sequenceNr, setLastSequenceNr, snapshotSequenceNr, snapshotStore, snapshotterId, startRecovery, unhandled, unstashAll, unstashFilterPredicate, updateLastSequenceNr, writeInProgress, writerUuid
deleteSnapshot, deleteSnapshots, loadSnapshot, saveSnapshot
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, postRestart, preStart, self, sender, supervisorStrategy
akka$actor$StashSupport$_setter_$akka$actor$StashSupport$$capacity_$eq, akka$actor$StashSupport$_setter_$mailbox_$eq, akka$actor$StashSupport$$capacity, akka$actor$StashSupport$$theStash_$eq, akka$actor$StashSupport$$theStash, clearStash, context, mailbox, prepend, self, stash, unstash, unstashAll
journalPluginId, persistenceId, snapshotPluginId
recovery
cancelTimer, currentState, Event, generation, handleEvent, handleEventDefault, handleTransition, initialize, isStateTimerActive, isTimerActive, logTermination, makeTransition, nextState, nextStateData, onTermination, onTransition, postStop, processMsg, receive, register, setStateTimeout, setTimer, startWith, stateData, stateFunctions, stateName, stateNames, StateTimeout, stateTimeouts, stay, stop, stop, stop, StopEvent, terminate, terminateEvent, timeoutFuture, timerGen, timers, total2pf, transform, transitionEvent, when, whenUnhandled