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.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 |
---|
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.Function1<D,scala.runtime.BoxedUnit> |
exec(java.util.function.Consumer<D> action)
Adapter from Java 8 Functional Interface to Scala Function
|
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
applyEvent, applyState, 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, debugEvent, Event, generation, handleEvent, handleEventDefault, handleTransition, initialize, isStateTimerActive, isTimerActive, logTermination, makeTransition, nextState, nextStateData, onTermination, onTransition, postStop, processEvent, 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
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