Package akka.persistence.fsm

Class AbstractPersistentFSM<S extends PersistentFSM.FSMState,D,E>

java.lang.Object

akka.persistence.fsm.AbstractPersistentFSMBase<S,D,E>

akka.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 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 akka.actor.Actor

Actor.emptyBehavior$, Actor.ignoringBehavior$

Nested classes/interfaces inherited from interface akka.persistence.Eventsourced

Eventsourced.AsyncHandlerInvocation, Eventsourced.AsyncHandlerInvocation$, Eventsourced.PendingHandlerInvocation, Eventsourced.RecoveryTick, Eventsourced.RecoveryTick$, Eventsourced.StashingHandlerInvocation, Eventsourced.StashingHandlerInvocation$

Nested classes/interfaces inherited from interface akka.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 akka.persistence.fsm.PersistentFSMBase

PersistentFSMBase.TransformHelper

Constructor Summary

Constructors

Constructor	Description
AbstractPersistentFSM()	Deprecated.

Method Summary

Modifier and Type	Method	Description
protected void	akka$actor$StashSupport$_setter_$mailbox_$eq(DequeBasedMessageQueueSemantics x$1)	Deprecated.
protected void	akka$persistence$fsm$PersistentFSM$_setter_$domainEventTag_$eq(scala.reflect.ClassTag<E> x$1)	Deprecated. Domain event's ClassTag Used for identifying domain events during recovery
abstract java.lang.Class<E>	domainEventClass()	Deprecated. Domain event's Class Used for identifying domain events during recovery
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
scala.Function1<D,scala.runtime.BoxedUnit>	exec(java.util.function.Consumer<D> action)	Deprecated. Adapter from Java 8 Functional Interface to Scala Function
protected ActorRef	journal()	Deprecated.
void	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 akka.persistence.fsm.AbstractPersistentFSMBase

$minus$greater, akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, akka$persistence$fsm$PersistentFSMBase$_setter_$Event_$eq, akka$persistence$fsm$PersistentFSMBase$_setter_$StateTimeout_$eq, akka$persistence$fsm$PersistentFSMBase$_setter_$StopEvent_$eq, akka$routing$Listeners$_setter_$listeners_$eq, 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, 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 akka.actor.Actor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, postRestart, preStart, self, sender, supervisorStrategy

Methods inherited from interface akka.actor.ActorLogging

_log_$eq, log

Methods inherited from interface akka.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 akka.routing.Listeners

akka$routing$Listeners$_setter_$listeners_$eq, gossip, gossip$default$2, listenerManagement, listeners

Methods inherited from interface akka.persistence.PersistenceIdentity

journalPluginId, persistenceId, snapshotPluginId

Methods inherited from interface akka.persistence.PersistenceRecovery

recovery

Methods inherited from interface akka.persistence.PersistenceStash

internalStashOverflowStrategy

Methods inherited from interface akka.persistence.PersistentActor

defer, deferAsync, persist, persistAll, persistAllAsync, persistAsync

Methods inherited from interface akka.persistence.fsm.PersistentFSM

applyEvent, applyState, currentStateTimeout_$eq, onRecoveryCompleted, receiveCommand, receiveRecover, saveStateSnapshot, super$applyState

Methods inherited from interface akka.persistence.fsm.PersistentFSMBase

$minus$greater, akka$persistence$fsm$PersistentFSMBase$_setter_$Event_$eq, akka$persistence$fsm$PersistentFSMBase$_setter_$StateTimeout_$eq, akka$persistence$fsm$PersistentFSMBase$_setter_$StopEvent_$eq, cancelTimer, currentState_$eq, debugEvent, Event, generation_$eq, handleEvent_$eq, handleTransition, initialize, isStateTimerActive, isTimerActive, logTermination, makeTransition, nextState_$eq, nextStateData, onTermination, onTransition, 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 akka.persistence.Snapshotter

deleteSnapshot, deleteSnapshots, loadSnapshot, saveSnapshot

Methods inherited from interface akka.actor.StashFactory

createStash

Methods inherited from interface akka.actor.StashSupport

actorCell, clearStash, context, enqueueFirst, prepend, self, theStash_$eq, unstash, unstashAll

Methods inherited from interface akka.actor.UnrestrictedStash

preRestart, super$postStop, super$preRestart

Constructor Detail

AbstractPersistentFSM

public AbstractPersistentFSM()

Deprecated.

Method Detail

akka$actor$StashSupport$_setter_$mailbox_$eq

protected void akka$actor$StashSupport$_setter_$mailbox_$eq(DequeBasedMessageQueueSemantics x$1)

Deprecated.

Specified by:

akka$actor$StashSupport$_setter_$mailbox_$eq in interface StashSupport

akka$persistence$fsm$PersistentFSM$_setter_$domainEventTag_$eq

protected void akka$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:

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

domainEventClass

public abstract java.lang.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(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 interface Eventsourced

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

Specified by:

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

Specified by:

postStop in interface UnrestrictedStash

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 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<java.lang.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>