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 expressions

Persistent 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

Modifier and Type	Method	Description
abstract Class<E>	domainEventClass()	Deprecated. Domain event's Class Used for identifying domain events during recovery
final scala.reflect.ClassTag<E>	domainEventClassTag()	Deprecated. Adapter from Java Class to ClassTag
scala.reflect.ClassTag<E>	domainEventTag()	Deprecated. Domain event's ClassTag Used for identifying domain events during recovery
final scala.Function1<D,scala.runtime.BoxedUnit>	exec(Consumer<D> action)	Deprecated. Adapter from Java 8 Functional Interface to Scala Function
protected 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's ClassTag Used for identifying domain events during recovery
void	postStop()	Deprecated. User overridable callback.
scala.PartialFunction<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<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

Constructor Details

AbstractPersistentFSM

public AbstractPersistentFSM()

Deprecated.

Method Details

domainEventClass

public abstract Class<E> domainEventClass()

Deprecated.

Domain event's Class Used for identifying domain events during recovery

domainEventClassTag

public final scala.reflect.ClassTag<E> domainEventClassTag()

Deprecated.

Adapter from Java Class to ClassTag

Specified by:

domainEventClassTag in interface PersistentFSM<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's ClassTag Used for identifying domain events during recovery

Specified by:

domainEventTag in interface PersistentFSM<S extends PersistentFSM.FSMState,D,E>

exec

public final scala.Function1<D,scala.runtime.BoxedUnit> exec(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 interface Eventsourced

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 interface StashSupport

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's ClassTag Used for identifying domain events during recovery

Specified by:

org$apache$pekko$persistence$fsm$PersistentFSM$_setter_$domainEventTag_$eq in interface PersistentFSM<S extends PersistentFSM.FSMState,D,E>

postStop

public void postStop()
              throws 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 interface Actor

Specified by:

postStop in interface PersistentFSMBase<S extends PersistentFSM.FSMState,D,E>

Specified by:

postStop in interface UnrestrictedStash

Throws:

Exception

receive

public scala.PartialFunction<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 interface Actor

Specified by:

receive in interface PersistentActor

Specified by:

receive in interface PersistentFSMBase<S extends PersistentFSM.FSMState,D,E>

snapshotStore

protected ActorRef snapshotStore()

Deprecated.

Description copied from interface: Snapshotter

Snapshot store plugin actor.

Specified by:

snapshotStore in interface Eventsourced

Specified by:

snapshotStore in interface Snapshotter

statesMap

public scala.collection.immutable.Map<String,S> statesMap()

Deprecated.

Description copied from interface: PersistentFSM

Map from state identifier to state instance

Specified by:

statesMap in interface PersistentFSM<S extends PersistentFSM.FSMState,D,E>