public abstract class AbstractPersistentFSM<S extends PersistentFSM.FSMState,D,E> extends AbstractPersistentFSMBase<S,D,E> implements PersistentFSM<S,D,E>
Persistent Finite State Machine actor abstract base class.
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 |
---|
AbstractPersistentFSM() |
Modifier and Type | Method and Description |
---|---|
abstract java.lang.Class<E> |
domainEventClass()
Domain event's
Class
Used for identifying domain events during recovery |
scala.reflect.ClassTag<E> |
domainEventClassTag()
Adapter from Java
Class to ClassTag |
scala.reflect.ClassTag<E> |
domainEventTag()
Domain event's
ClassTag
Used for identifying domain events during recovery |
scala.Function1<D,scala.runtime.BoxedUnit> |
exec(java.util.function.Consumer<D> action)
Adapter from Java 8 Functional Interface to Scala Function
|
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, debugEvent, 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, whenUnhandled
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
applyEvent, applyState, onRecoveryCompleted, receiveCommand, receiveRecover, saveStateSnapshot
receive
aroundPostRestart, 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, waitingRecoveryPermit
deleteSnapshot, deleteSnapshots, loadSnapshot, saveSnapshot
internalStashOverflowStrategy
context, postRestart, preStart, self, sender, supervisorStrategy
actorCell, clearStash, context, enqueueFirst, prepend, self, stash, unstash, unstashAll
createStash
journalPluginId, persistenceId, snapshotPluginId
recovery
cancelTimer, debugEvent, Event, handleTransition, initialize, isStateTimerActive, isTimerActive, logTermination, makeTransition, nextStateData, onTermination, onTransition, postStop, processEvent, processMsg, receive, register, setStateTimeout, setTimer, startWith, stateData, stateName, stateNames, StateTimeout, stay, stop, stop, stop, StopEvent, terminate, total2pf, transform, when, whenUnhandled
gossip, listenerManagement, listeners
log
public scala.reflect.ClassTag<E> domainEventTag()
PersistentFSM
ClassTag
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()
PersistentFSM
statesMap
in interface PersistentFSM<S extends PersistentFSM.FSMState,D,E>
protected ActorRef journal()
journal
in interface Eventsourced
protected ActorRef snapshotStore()
Snapshotter
snapshotStore
in interface Eventsourced
snapshotStore
in interface Snapshotter
public DequeBasedMessageQueueSemantics mailbox()
mailbox
in interface StashSupport
public final scala.Function1<D,scala.runtime.BoxedUnit> exec(java.util.function.Consumer<D> action)
action
- - Java 8 lambda expression defining the actionpublic final scala.reflect.ClassTag<E> domainEventClassTag()
Class
to ClassTag
domainEventClassTag
in interface PersistentFSM<S extends PersistentFSM.FSMState,D,E>
ClassTag
public abstract java.lang.Class<E> domainEventClass()
Class
Used for identifying domain events during recovery