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.PersistentFSMSnapshot<D>, PersistentFSM.PersistentFSMSnapshot$, 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.RecoveryTick, Eventsourced.RecoveryTick$, Eventsourced.StashingHandlerInvocation, Eventsourced.StashingHandlerInvocation$Actor.emptyBehavior$, Actor.ignoringBehavior$PersistentFSMBase.TransformHelper| Constructor and Description |
|---|
AbstractPersistentLoggingFSM() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
debugEvent() |
scala.reflect.ClassTag<E> |
domainEventTag()
Domain event's
ClassTag
Used for identifying domain events during recovery |
protected ActorRef |
journal() |
DequeBasedMessageQueueSemantics |
mailbox() |
protected ActorRef |
snapshotStore()
Snapshot store plugin actor.
|
scala.collection.immutable.Map<java.lang.String,S> |
statesMap()
Map from state identifier to state instance
|
$minus$greater, akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, akka$actor$ActorLogging$$_log_$eq, akka$actor$ActorLogging$$_log, akka$persistence$fsm$PersistentFSMBase$_setter_$$minus$greater_$eq, akka$persistence$fsm$PersistentFSMBase$_setter_$akka$persistence$fsm$PersistentFSMBase$$handleEventDefault_$eq, akka$persistence$fsm$PersistentFSMBase$_setter_$akka$persistence$fsm$PersistentFSMBase$$stateFunctions_$eq, akka$persistence$fsm$PersistentFSMBase$_setter_$akka$persistence$fsm$PersistentFSMBase$$stateTimeouts_$eq, akka$persistence$fsm$PersistentFSMBase$_setter_$akka$persistence$fsm$PersistentFSMBase$$timerGen_$eq, akka$persistence$fsm$PersistentFSMBase$_setter_$akka$persistence$fsm$PersistentFSMBase$$timers_$eq, akka$persistence$fsm$PersistentFSMBase$_setter_$Event_$eq, akka$persistence$fsm$PersistentFSMBase$_setter_$StateTimeout_$eq, akka$persistence$fsm$PersistentFSMBase$_setter_$StopEvent_$eq, akka$persistence$fsm$PersistentFSMBase$$currentState_$eq, akka$persistence$fsm$PersistentFSMBase$$currentState, akka$persistence$fsm$PersistentFSMBase$$generation_$eq, akka$persistence$fsm$PersistentFSMBase$$generation, akka$persistence$fsm$PersistentFSMBase$$handleEvent_$eq, akka$persistence$fsm$PersistentFSMBase$$handleEvent, akka$persistence$fsm$PersistentFSMBase$$handleEventDefault, akka$persistence$fsm$PersistentFSMBase$$nextState_$eq, akka$persistence$fsm$PersistentFSMBase$$nextState, akka$persistence$fsm$PersistentFSMBase$$stateFunctions, akka$persistence$fsm$PersistentFSMBase$$stateTimeouts, akka$persistence$fsm$PersistentFSMBase$$terminateEvent_$eq, akka$persistence$fsm$PersistentFSMBase$$terminateEvent, akka$persistence$fsm$PersistentFSMBase$$timeoutFuture_$eq, akka$persistence$fsm$PersistentFSMBase$$timeoutFuture, akka$persistence$fsm$PersistentFSMBase$$timerGen, akka$persistence$fsm$PersistentFSMBase$$timers, akka$persistence$fsm$PersistentFSMBase$$transitionEvent_$eq, akka$persistence$fsm$PersistentFSMBase$$transitionEvent, akka$routing$Listeners$_setter_$listeners_$eq, applyState, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, cancelTimer, context, Event, gossip, gossip$default$2, goTo, initialize, isStateTimerActive, isTimerActive, listenerManagement, listeners, log, logTermination, makeTransition, matchAnyEvent, matchData, matchData, matchEvent, matchEvent, matchEvent, matchEvent, matchEvent, matchEvent, matchEvent, matchEventEquals, matchEventEquals, matchState, matchState, matchStop, matchStop, matchStop, nextStateData, Normal, NullFunction, onTermination, onTransition, onTransition, postRestart, postStop, preRestart, preStart, processEvent, receive, self, sender, setStateTimeout, setTimer, setTimer$default$4, Shutdown, startWith, startWith, startWith$default$3, stateData, stateName, stateNames, StateTimeout, stay, stop, stop, stop, StopEvent, supervisorStrategy, total2pf, transform, unhandled, when, when, when, when$default$2, whenUnhandledclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitadvance, getLog, logDepth, processEventapplyEvent, applyState, domainEventClassTag, onRecoveryCompleted, receiveCommand, receiveRecover, saveStateSnapshotreceivearoundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, changeState, deferAsync, deleteMessages, flushBatch, flushJournalBatch, lastSequenceNr, log, nextSequenceNr, onPersistFailure, onPersistRejected, onRecoveryFailure, onReplaySuccess, peekApplyHandler, persist, persist, persistAll, persistAllAsync, persistAsync, persistAsync, recovering, recoveryFinished, recoveryRunning, recoveryStarted, requestRecoveryPermit, setLastSequenceNr, snapshotSequenceNr, snapshotterId, startRecovery, stashInternally, unhandled, unstashAll, unstashInternally, updateLastSequenceNr, waitingRecoveryPermitdeleteSnapshot, deleteSnapshots, loadSnapshot, saveSnapshotinternalStashOverflowStrategycontext, postRestart, preStart, self, sender, supervisorStrategyactorCell, clearStash, context, enqueueFirst, prepend, self, stash, unstash, unstashAllcreateStashjournalPluginId, persistenceId, snapshotPluginIdrecoverycancelTimer, Event, handleTransition, initialize, isStateTimerActive, isTimerActive, logTermination, makeTransition, nextStateData, onTermination, onTransition, postStop, processMsg, receive, register, setStateTimeout, setTimer, startWith, stateData, stateName, stateNames, StateTimeout, stay, stop, stop, stop, StopEvent, terminate, total2pf, transform, when, whenUnhandledgossip, listenerManagement, listenerslogpublic scala.reflect.ClassTag<E> domainEventTag()
PersistentFSMClassTag
Used for identifying domain events during recoverydomainEventTag in interface PersistentFSM<S extends PersistentFSM.FSMState,D,E>public scala.collection.immutable.Map<java.lang.String,S> statesMap()
PersistentFSMstatesMap in interface PersistentFSM<S extends PersistentFSM.FSMState,D,E>protected ActorRef journal()
journal in interface Eventsourcedprotected ActorRef snapshotStore()
SnapshottersnapshotStore in interface EventsourcedsnapshotStore in interface Snapshotterpublic DequeBasedMessageQueueSemantics mailbox()
mailbox in interface StashSupportpublic boolean debugEvent()
debugEvent in interface LoggingPersistentFSM<S extends PersistentFSM.FSMState,D,E>debugEvent in interface PersistentFSMBase<S extends PersistentFSM.FSMState,D,E>debugEvent in class AbstractPersistentFSMBase<S extends PersistentFSM.FSMState,D,E>