Package org.apache.pekko.persistence.fsm
Class AbstractPersistentLoggingFSM<S extends PersistentFSM.FSMState,D,E>
java.lang.Object
org.apache.pekko.persistence.fsm.AbstractPersistentFSMBase<S,D,E>
org.apache.pekko.persistence.fsm.AbstractPersistentFSM<S,D,E>
org.apache.pekko.persistence.fsm.AbstractPersistentLoggingFSM<S,D,E>
- All Implemented Interfaces:
Actor
,ActorLogging
,Stash
,StashFactory
,StashSupport
,UnrestrictedStash
,RequiresMessageQueue<DequeBasedMessageQueueSemantics>
,Eventsourced
,LoggingPersistentFSM<S,
,D, E> PersistentFSM<S,
,D, E> PersistentFSMBase<S,
,D, E> PersistenceIdentity
,PersistenceRecovery
,PersistenceStash
,PersistentActor
,Snapshotter
,Listeners
public abstract class AbstractPersistentLoggingFSM<S extends PersistentFSM.FSMState,D,E>
extends AbstractPersistentFSM<S,D,E>
implements LoggingPersistentFSM<S,D,E>, PersistentFSM<S,D,E>
Deprecated.
Use EventSourcedBehavior. Since Akka 2.6.0.
Java API: compatible with lambda expressions
Persistent Finite State Machine actor abstract base class with FSM Logging
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.pekko.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
Nested classes/interfaces inherited from interface org.apache.pekko.persistence.Eventsourced
Eventsourced.AsyncHandlerInvocation, Eventsourced.AsyncHandlerInvocation$, Eventsourced.PendingHandlerInvocation, Eventsourced.RecoveryTick, Eventsourced.RecoveryTick$, Eventsourced.StashingHandlerInvocation, Eventsourced.StashingHandlerInvocation$
Nested classes/interfaces inherited from interface org.apache.pekko.persistence.fsm.PersistentFSM
PersistentFSM.$minus$greater$, PersistentFSM.CurrentState<S>, PersistentFSM.CurrentState$, PersistentFSM.Event<D>, PersistentFSM.Event$, PersistentFSM.Failure, PersistentFSM.Failure$, PersistentFSM.FixedDelayMode$, PersistentFSM.FixedRateMode$, PersistentFSM.FSMState, PersistentFSM.LogEntry<S,
D>, PersistentFSM.LogEntry$, PersistentFSM.Normal$, PersistentFSM.NullFunction$, PersistentFSM.PersistentFsmEvent, PersistentFSM.PersistentFSMSnapshot<D>, PersistentFSM.PersistentFSMSnapshot$, PersistentFSM.Reason, PersistentFSM.Shutdown$, PersistentFSM.SingleMode$, 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.TimerMode, PersistentFSM.Transition<S>, PersistentFSM.Transition$, PersistentFSM.UnsubscribeTransitionCallBack, PersistentFSM.UnsubscribeTransitionCallBack$ Nested classes/interfaces inherited from interface org.apache.pekko.persistence.fsm.PersistentFSMBase
PersistentFSMBase.TransformHelper
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected void
Deprecated.Methods inherited from class org.apache.pekko.persistence.fsm.AbstractPersistentFSM
domainEventClass, domainEventClassTag, domainEventTag, exec, journal, org$apache$pekko$actor$StashSupport$_setter_$mailbox_$eq, org$apache$pekko$persistence$fsm$PersistentFSM$_setter_$domainEventTag_$eq, postStop, receive, snapshotStore, statesMap
Methods inherited from class org.apache.pekko.persistence.fsm.AbstractPersistentFSMBase
$minus$greater, context, Event, getContext, getSelf, getSender, goTo, listeners, matchAnyEvent, matchData, matchData, matchEvent, matchEvent, matchEvent, matchEvent, matchEvent, matchEvent, matchEvent, matchEventEquals, matchEventEquals, matchState, matchState, matchStop, matchStop, matchStop, Normal, NullFunction, onTermination, onTransition, onTransition, org$apache$pekko$actor$Actor$_setter_$context_$eq, org$apache$pekko$actor$Actor$_setter_$self_$eq, org$apache$pekko$persistence$fsm$PersistentFSMBase$_setter_$Event_$eq, org$apache$pekko$persistence$fsm$PersistentFSMBase$_setter_$StateTimeout_$eq, org$apache$pekko$persistence$fsm$PersistentFSMBase$_setter_$StopEvent_$eq, org$apache$pekko$routing$Listeners$_setter_$listeners_$eq, self, setTimer, Shutdown, startSingleTimer, startTimerAtFixedRate, startTimerWithFixedDelay, startWith, startWith, StateTimeout, StopEvent, when, when, when, whenUnhandled
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.pekko.actor.Actor
context, org$apache$pekko$actor$Actor$_setter_$context_$eq, org$apache$pekko$actor$Actor$_setter_$self_$eq, postRestart, preStart, self, sender, supervisorStrategy
Methods inherited from interface org.apache.pekko.actor.ActorLogging
_log_$eq, log
Methods inherited from interface org.apache.pekko.persistence.Eventsourced
_lastSequenceNr_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, batchAtomicWrite, changeState, currentState_$eq, deleteMessages, eventBatch_$eq, flushBatch, flushJournalBatch, internalDefer, internalDeferAsync, internalDeleteMessagesBeforeSnapshot, internalPersist, internalPersistAll, internalPersistAllAsync, internalPersistAsync, journal, journalBatch_$eq, lastSequenceNr, log, nextSequenceNr, onPersistFailure, onPersistRejected, onRecoveryFailure, onReplaySuccess, peekApplyHandler, pendingStashingPersistInvocations_$eq, recovering, recoveryFinished, recoveryRunning, recoveryStarted, requestRecoveryPermit, sendBatchedEventsToJournal, sequenceNr_$eq, setLastSequenceNr, snapshotSequenceNr, snapshotStore, snapshotterId, startRecovery, stash, stashInternally, super$aroundPostRestart, super$aroundPostStop, super$aroundPreRestart, super$aroundPreStart, super$aroundReceive, super$stash, super$unhandled, unhandled, unstashAll, unstashInternally, updateLastSequenceNr, waitingRecoveryPermit, writeEventFailed, writeEventRejected, writeEventSucceeded, writeInProgress_$eq
Methods inherited from interface org.apache.pekko.routing.Listeners
gossip, gossip$default$2, listenerManagement, listeners, org$apache$pekko$routing$Listeners$_setter_$listeners_$eq
Methods inherited from interface org.apache.pekko.persistence.fsm.LoggingPersistentFSM
advance, full_$eq, getLog, logDepth, pos_$eq, processEvent, super$processEvent
Methods inherited from interface org.apache.pekko.persistence.PersistenceIdentity
journalPluginId, persistenceId, snapshotPluginId
Methods inherited from interface org.apache.pekko.persistence.PersistenceRecovery
recovery
Methods inherited from interface org.apache.pekko.persistence.PersistenceStash
internalStashOverflowStrategy
Methods inherited from interface org.apache.pekko.persistence.PersistentActor
defer, deferAsync, persist, persistAll, persistAllAsync, persistAsync, receive
Methods inherited from interface org.apache.pekko.persistence.fsm.PersistentFSM
applyEvent, applyState, currentStateTimeout_$eq, domainEventClassTag, domainEventTag, onRecoveryCompleted, org$apache$pekko$persistence$fsm$PersistentFSM$_setter_$domainEventTag_$eq, receiveCommand, receiveRecover, saveStateSnapshot, statesMap, super$applyState
Methods inherited from interface org.apache.pekko.persistence.fsm.PersistentFSMBase
$minus$greater, cancelTimer, currentState_$eq, Event, generation_$eq, handleEvent_$eq, handleTransition, initialize, isStateTimerActive, isTimerActive, logTermination, makeTransition, nextState_$eq, nextStateData, onTermination, onTransition, org$apache$pekko$persistence$fsm$PersistentFSMBase$_setter_$Event_$eq, org$apache$pekko$persistence$fsm$PersistentFSMBase$_setter_$StateTimeout_$eq, org$apache$pekko$persistence$fsm$PersistentFSMBase$_setter_$StopEvent_$eq, postStop, processMsg, receive, register, setStateTimeout, setTimer, setTimer$default$4, startSingleTimer, startTimer, startTimerAtFixedRate, startTimerWithFixedDelay, startWith, startWith$default$3, stateData, stateName, stateNames, StateTimeout, stay, stop, stop, stop, StopEvent, super$postStop, terminate, terminateEvent_$eq, timeoutFuture_$eq, total2pf, transform, transitionEvent_$eq, when, when$default$2, whenUnhandled
Methods inherited from interface org.apache.pekko.persistence.Snapshotter
deleteSnapshot, deleteSnapshots, loadSnapshot, saveSnapshot
Methods inherited from interface org.apache.pekko.actor.StashFactory
createStash
Methods inherited from interface org.apache.pekko.actor.StashSupport
actorCell, clearStash, context, enqueueFirst, mailbox, org$apache$pekko$actor$StashSupport$_setter_$mailbox_$eq, prepend, self, theStash_$eq, unstash, unstashAll
Methods inherited from interface org.apache.pekko.actor.UnrestrictedStash
postStop, preRestart, super$postStop, super$preRestart
-
Constructor Details
-
AbstractPersistentLoggingFSM
public AbstractPersistentLoggingFSM()Deprecated.
-
-
Method Details
-
org$apache$pekko$persistence$fsm$LoggingPersistentFSM$_setter_$debugEvent_$eq
protected void org$apache$pekko$persistence$fsm$LoggingPersistentFSM$_setter_$debugEvent_$eq(boolean x$1) Deprecated.- Specified by:
org$apache$pekko$persistence$fsm$LoggingPersistentFSM$_setter_$debugEvent_$eq
in interfaceLoggingPersistentFSM<S extends PersistentFSM.FSMState,
D, E>
-