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>
Adapter from Java 8 Functional Interface to Scala Function param: action - Java 8 lambda expression defining the action
-
-
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.FSMState, PersistentFSM.LogEntry<S,D>, PersistentFSM.LogEntry$, PersistentFSM.Normal$, PersistentFSM.NullFunction$, PersistentFSM.PersistentFsmEvent, PersistentFSM.PersistentFSMSnapshot<D>, PersistentFSM.PersistentFSMSnapshot$, 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$
-
Nested classes/interfaces inherited from interface akka.persistence.fsm.PersistentFSMBase
PersistentFSMBase.TransformHelper
-
-
Constructor Summary
Constructors Constructor Description AbstractPersistentFSM()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected void
akka$actor$StashSupport$_setter_$mailbox_$eq(DequeBasedMessageQueueSemantics x$1)
protected void
akka$persistence$fsm$PersistentFSM$_setter_$domainEventTag_$eq(scala.reflect.ClassTag<E> x$1)
Domain event'sClassTag
Used for identifying domain events during recoveryabstract java.lang.Class<E>
domainEventClass()
Domain event'sClass
Used for identifying domain events during recoveryscala.reflect.ClassTag<E>
domainEventClassTag()
Adapter from JavaClass
toClassTag
scala.reflect.ClassTag<E>
domainEventTag()
Domain event'sClassTag
Used for identifying domain events during recoveryscala.Function1<D,scala.runtime.BoxedUnit>
exec(java.util.function.Consumer<D> action)
protected ActorRef
journal()
DequeBasedMessageQueueSemantics
mailbox()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receive()
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.protected ActorRef
snapshotStore()
Snapshot store plugin actor.scala.collection.immutable.Map<java.lang.String,S>
statesMap()
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, 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, postStop, processEvent, processMsg, register, setStateTimeout, setTimer, setTimer$default$4, 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
postStop, preRestart, super$postStop, super$preRestart
-
-
-
-
Method Detail
-
akka$actor$StashSupport$_setter_$mailbox_$eq
protected void akka$actor$StashSupport$_setter_$mailbox_$eq(DequeBasedMessageQueueSemantics x$1)
- Specified by:
akka$actor$StashSupport$_setter_$mailbox_$eq
in interfaceStashSupport
-
akka$persistence$fsm$PersistentFSM$_setter_$domainEventTag_$eq
protected void akka$persistence$fsm$PersistentFSM$_setter_$domainEventTag_$eq(scala.reflect.ClassTag<E> x$1)
Description copied from interface:PersistentFSM
Domain event'sClassTag
Used for identifying domain events during recovery- Specified by:
akka$persistence$fsm$PersistentFSM$_setter_$domainEventTag_$eq
in interfacePersistentFSM<S extends PersistentFSM.FSMState,D,E>
- Parameters:
x$1
- (undocumented)
-
domainEventClass
public abstract java.lang.Class<E> domainEventClass()
Domain event'sClass
Used for identifying domain events during recovery- Returns:
- (undocumented)
-
domainEventClassTag
public final scala.reflect.ClassTag<E> domainEventClassTag()
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()
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>
- Returns:
- (undocumented)
-
exec
public final scala.Function1<D,scala.runtime.BoxedUnit> exec(java.util.function.Consumer<D> action)
-
journal
protected ActorRef journal()
- Specified by:
journal
in interfaceEventsourced
-
mailbox
public DequeBasedMessageQueueSemantics mailbox()
- Specified by:
mailbox
in interfaceStashSupport
-
receive
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
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>
- Returns:
- (undocumented)
-
snapshotStore
protected ActorRef snapshotStore()
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()
Description copied from interface:PersistentFSM
Map from state identifier to state instance- Specified by:
statesMap
in interfacePersistentFSM<S extends PersistentFSM.FSMState,D,E>
- Returns:
- (undocumented)
-
-