Package org.apache.pekko.persistence.fsm
Class AbstractPersistentFSM<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>
-
- All Implemented Interfaces:
Actor
,ActorLogging
,Stash
,StashFactory
,StashSupport
,UnrestrictedStash
,RequiresMessageQueue<DequeBasedMessageQueueSemantics>
,Eventsourced
,PersistentFSM<S,D,E>
,PersistentFSMBase<S,D,E>
,PersistenceIdentity
,PersistenceRecovery
,PersistenceStash
,PersistentActor
,Snapshotter
,Listeners
- Direct Known Subclasses:
AbstractPersistentLoggingFSM
public abstract class AbstractPersistentFSM<S extends PersistentFSM.FSMState,D,E> extends AbstractPersistentFSMBase<S,D,E> implements PersistentFSM<S,D,E>
Deprecated.Use EventSourcedBehavior. Since Akka 2.6.0.Java API: compatible with lambda expressionsPersistent Finite State Machine actor abstract base class.
-
-
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 Constructor Description AbstractPersistentFSM()
Deprecated.
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Deprecated Methods Modifier and Type Method Description abstract java.lang.Class<E>
domainEventClass()
Deprecated.Domain event'sClass
Used for identifying domain events during recoveryscala.reflect.ClassTag<E>
domainEventClassTag()
Deprecated.Adapter from JavaClass
toClassTag
scala.reflect.ClassTag<E>
domainEventTag()
Deprecated.Domain event'sClassTag
Used for identifying domain events during recoveryscala.Function1<D,scala.runtime.BoxedUnit>
exec(java.util.function.Consumer<D> action)
Deprecated.Adapter from Java 8 Functional Interface to Scala Functionprotected ActorRef
journal()
Deprecated.protected void
org$apache$pekko$actor$StashSupport$_setter_$mailbox_$eq(DequeBasedMessageQueueSemantics x$1)
Deprecated.protected void
org$apache$pekko$persistence$fsm$PersistentFSM$_setter_$domainEventTag_$eq(scala.reflect.ClassTag<E> x$1)
Deprecated.Domain event'sClassTag
Used for identifying domain events during recoveryvoid
postStop()
Deprecated.User overridable callback.scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receive()
Deprecated.Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.protected ActorRef
snapshotStore()
Deprecated.Snapshot store plugin actor.scala.collection.immutable.Map<java.lang.String,S>
statesMap()
Deprecated.Map from state identifier to state instance-
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, journalBatch_$eq, lastSequenceNr, log, nextSequenceNr, onPersistFailure, onPersistRejected, onRecoveryFailure, onReplaySuccess, peekApplyHandler, pendingStashingPersistInvocations_$eq, recovering, recoveryFinished, recoveryRunning, recoveryStarted, requestRecoveryPermit, sendBatchedEventsToJournal, sequenceNr_$eq, setLastSequenceNr, snapshotSequenceNr, 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.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
-
Methods inherited from interface org.apache.pekko.persistence.fsm.PersistentFSM
applyEvent, applyState, currentStateTimeout_$eq, onRecoveryCompleted, receiveCommand, receiveRecover, saveStateSnapshot, super$applyState
-
Methods inherited from interface org.apache.pekko.persistence.fsm.PersistentFSMBase
$minus$greater, cancelTimer, currentState_$eq, debugEvent, 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, processEvent, processMsg, 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, prepend, self, theStash_$eq, unstash, unstashAll
-
Methods inherited from interface org.apache.pekko.actor.UnrestrictedStash
preRestart, super$postStop, super$preRestart
-
-
-
-
Method Detail
-
domainEventClass
public abstract java.lang.Class<E> domainEventClass()
Deprecated.Domain event'sClass
Used for identifying domain events during recovery
-
domainEventClassTag
public final scala.reflect.ClassTag<E> domainEventClassTag()
Deprecated.Adapter from JavaClass
toClassTag
- Specified by:
domainEventClassTag
in interfacePersistentFSM<S extends PersistentFSM.FSMState,D,E>
- Returns:
- domain event
ClassTag
-
domainEventTag
public scala.reflect.ClassTag<E> domainEventTag()
Deprecated.Description copied from interface:PersistentFSM
Domain event'sClassTag
Used for identifying domain events during recovery- Specified by:
domainEventTag
in interfacePersistentFSM<S extends PersistentFSM.FSMState,D,E>
-
exec
public final scala.Function1<D,scala.runtime.BoxedUnit> exec(java.util.function.Consumer<D> action)
Deprecated.Adapter from Java 8 Functional Interface to Scala Function- Parameters:
action
- - Java 8 lambda expression defining the action- Returns:
- action represented as a Scala Function
-
journal
protected ActorRef journal()
Deprecated.- Specified by:
journal
in interfaceEventsourced
-
org$apache$pekko$actor$StashSupport$_setter_$mailbox_$eq
protected void org$apache$pekko$actor$StashSupport$_setter_$mailbox_$eq(DequeBasedMessageQueueSemantics x$1)
Deprecated.- Specified by:
org$apache$pekko$actor$StashSupport$_setter_$mailbox_$eq
in interfaceStashSupport
-
org$apache$pekko$persistence$fsm$PersistentFSM$_setter_$domainEventTag_$eq
protected void org$apache$pekko$persistence$fsm$PersistentFSM$_setter_$domainEventTag_$eq(scala.reflect.ClassTag<E> x$1)
Deprecated.Description copied from interface:PersistentFSM
Domain event'sClassTag
Used for identifying domain events during recovery- Specified by:
org$apache$pekko$persistence$fsm$PersistentFSM$_setter_$domainEventTag_$eq
in interfacePersistentFSM<S extends PersistentFSM.FSMState,D,E>
-
postStop
public void postStop() throws java.lang.Exception
Deprecated.Description copied from interface:Actor
User overridable callback. Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.- Specified by:
postStop
in interfaceActor
- Specified by:
postStop
in interfacePersistentFSMBase<S extends PersistentFSM.FSMState,D,E>
- Specified by:
postStop
in interfaceUnrestrictedStash
- Throws:
java.lang.Exception
-
receive
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Deprecated.Description copied from interface:Actor
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.- Specified by:
receive
in interfaceActor
- Specified by:
receive
in interfacePersistentActor
- Specified by:
receive
in interfacePersistentFSMBase<S extends PersistentFSM.FSMState,D,E>
-
snapshotStore
protected ActorRef snapshotStore()
Deprecated.Description copied from interface:Snapshotter
Snapshot store plugin actor.- Specified by:
snapshotStore
in interfaceEventsourced
- Specified by:
snapshotStore
in interfaceSnapshotter
-
statesMap
public scala.collection.immutable.Map<java.lang.String,S> statesMap()
Deprecated.Description copied from interface:PersistentFSM
Map from state identifier to state instance- Specified by:
statesMap
in interfacePersistentFSM<S extends PersistentFSM.FSMState,D,E>
-
-