Interface PersistentFSMBase<S,D,E>
-
- All Superinterfaces:
Actor
,ActorLogging
,Listeners
- All Known Subinterfaces:
LoggingPersistentFSM<S,D,E>
,PersistentFSM<S,D,E>
- All Known Implementing Classes:
AbstractPersistentFSM
,AbstractPersistentFSMBase
,AbstractPersistentLoggingFSM
public interface PersistentFSMBase<S,D,E> extends Actor, Listeners, ActorLogging
This extractor is just convenience for matching a (S, S) pair, including a reminder what the new state is.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static class
PersistentFSMBase.TransformHelper
-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Method Summary
All Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method Description PersistentFSM.$minus$greater$
$minus$greater()
This extractor is just convenience for matching a (S, S) pair, including a reminder what the new state is.void
akka$persistence$fsm$PersistentFSMBase$_setter_$Event_$eq(PersistentFSM.Event$ x$1)
void
akka$persistence$fsm$PersistentFSMBase$_setter_$StateTimeout_$eq(PersistentFSM.StateTimeout$ x$1)
This case object is received in case of a state timeout.void
akka$persistence$fsm$PersistentFSMBase$_setter_$StopEvent_$eq(PersistentFSM.StopEvent$ x$1)
void
applyState(PersistentFSM.State<S,D,E> nextState)
void
cancelTimer(java.lang.String name)
Cancel named timer, ensuring that the message is not subsequently delivered (no race).void
currentState_$eq(PersistentFSM.State<S,D,E> x$1)
boolean
debugEvent()
PersistentFSM.Event$
Event()
void
generation_$eq(long x$1)
void
handleEvent_$eq(scala.PartialFunction<PersistentFSM.Event<D>,PersistentFSM.State<S,D,E>> x$1)
void
handleTransition(S prev, S next)
void
initialize()
Deprecated.Removed from API, called internally.boolean
isStateTimerActive()
INTERNAL API, used for testing.boolean
isTimerActive(java.lang.String name)
Inquire whether the named timer is still active.void
logTermination(PersistentFSM.Reason reason)
By defaultPersistentFSM.Failure
is logged at error level and other reason types are not logged.void
makeTransition(PersistentFSM.State<S,D,E> nextState)
void
nextState_$eq(PersistentFSM.State<S,D,E> x$1)
D
nextStateData()
Return next state data (available in onTransition handlers)void
onTermination(scala.PartialFunction<PersistentFSM.StopEvent<S,D>,scala.runtime.BoxedUnit> terminationHandler)
Set handler which is called upon termination of this FSM actor.void
onTransition(scala.PartialFunction<scala.Tuple2<S,S>,scala.runtime.BoxedUnit> transitionHandler)
Set handler which is called upon each state transition, i.e.void
postStop()
CallonTermination
hook; if you want to retain this behavior when overriding make sure to callsuper.postStop()
.void
processEvent(PersistentFSM.Event<D> event, java.lang.Object source)
void
processMsg(java.lang.Object value, java.lang.Object source)
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.void
register(S name, scala.PartialFunction<PersistentFSM.Event<D>,PersistentFSM.State<S,D,E>> function, scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
void
setStateTimeout(S state, scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
Set state timeout explicitly.void
setTimer(java.lang.String name, java.lang.Object msg, scala.concurrent.duration.FiniteDuration timeout, boolean repeat)
Schedule named timer to deliver message after given delay, possibly repeating.boolean
setTimer$default$4()
void
startWith(S stateName, D stateData, scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
Set initial state.scala.Option<scala.concurrent.duration.FiniteDuration>
startWith$default$3()
D
stateData()
Return current state data (i.e.S
stateName()
Return current state name (i.e.scala.collection.Iterable<S>
stateNames()
Return all defined state namesPersistentFSM.StateTimeout$
StateTimeout()
This case object is received in case of a state timeout.PersistentFSM.State<S,D,E>
stay()
Produce "empty" transition descriptor.PersistentFSM.State<S,D,E>
stop()
Produce change descriptor to stop this FSM actor with reason "Normal".PersistentFSM.State<S,D,E>
stop(PersistentFSM.Reason reason)
Produce change descriptor to stop this FSM actor including specified reason.PersistentFSM.State<S,D,E>
stop(PersistentFSM.Reason reason, D stateData)
Produce change descriptor to stop this FSM actor including specified reason.PersistentFSM.StopEvent$
StopEvent()
void
super$postStop()
CallonTermination
hook; if you want to retain this behavior when overriding make sure to callsuper.postStop()
.void
terminate(PersistentFSM.State<S,D,E> nextState)
void
terminateEvent_$eq(scala.PartialFunction<PersistentFSM.StopEvent<S,D>,scala.runtime.BoxedUnit> x$1)
void
timeoutFuture_$eq(scala.Option<Cancellable> x$1)
scala.PartialFunction<scala.Tuple2<S,S>,scala.runtime.BoxedUnit>
total2pf(scala.Function2<S,S,scala.runtime.BoxedUnit> transitionHandler)
Convenience wrapper for using a total function instead of a partial function literal.PersistentFSMBase.TransformHelper
transform(scala.PartialFunction<PersistentFSM.Event<D>,PersistentFSM.State<S,D,E>> func)
void
transitionEvent_$eq(scala.collection.immutable.List<scala.PartialFunction<scala.Tuple2<S,S>,scala.runtime.BoxedUnit>> x$1)
void
when(S stateName, scala.concurrent.duration.FiniteDuration stateTimeout, scala.PartialFunction<PersistentFSM.Event<D>,PersistentFSM.State<S,D,E>> stateFunction)
Insert a new StateFunction at the end of the processing chain for the given state.scala.concurrent.duration.FiniteDuration
when$default$2()
void
whenUnhandled(scala.PartialFunction<PersistentFSM.Event<D>,PersistentFSM.State<S,D,E>> stateFunction)
Set handler which is called upon reception of unhandled messages.-
Methods inherited from interface akka.actor.Actor
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, preStart, self, sender, supervisorStrategy, unhandled
-
Methods inherited from interface akka.actor.ActorLogging
_log_$eq, log
-
Methods inherited from interface akka.routing.Listeners
akka$routing$Listeners$_setter_$listeners_$eq, gossip, gossip$default$2, listenerManagement, listeners
-
-
-
-
Method Detail
-
$minus$greater
PersistentFSM.$minus$greater$ $minus$greater()
This extractor is just convenience for matching a (S, S) pair, including a reminder what the new state is.- Returns:
- (undocumented)
-
Event
PersistentFSM.Event$ Event()
-
StateTimeout
PersistentFSM.StateTimeout$ StateTimeout()
This case object is received in case of a state timeout.- Returns:
- (undocumented)
-
StopEvent
PersistentFSM.StopEvent$ StopEvent()
-
akka$persistence$fsm$PersistentFSMBase$_setter_$Event_$eq
void akka$persistence$fsm$PersistentFSMBase$_setter_$Event_$eq(PersistentFSM.Event$ x$1)
-
akka$persistence$fsm$PersistentFSMBase$_setter_$StateTimeout_$eq
void akka$persistence$fsm$PersistentFSMBase$_setter_$StateTimeout_$eq(PersistentFSM.StateTimeout$ x$1)
This case object is received in case of a state timeout.- Parameters:
x$1
- (undocumented)
-
akka$persistence$fsm$PersistentFSMBase$_setter_$StopEvent_$eq
void akka$persistence$fsm$PersistentFSMBase$_setter_$StopEvent_$eq(PersistentFSM.StopEvent$ x$1)
-
applyState
void applyState(PersistentFSM.State<S,D,E> nextState)
-
cancelTimer
void cancelTimer(java.lang.String name)
Cancel named timer, ensuring that the message is not subsequently delivered (no race).- Parameters:
name
- of the timer to cancel
-
currentState_$eq
void currentState_$eq(PersistentFSM.State<S,D,E> x$1)
-
debugEvent
boolean debugEvent()
-
generation_$eq
void generation_$eq(long x$1)
-
handleEvent_$eq
void handleEvent_$eq(scala.PartialFunction<PersistentFSM.Event<D>,PersistentFSM.State<S,D,E>> x$1)
-
initialize
void initialize()
Deprecated.Removed from API, called internally. Since 2.4.5.Verify existence of initial state and setup timers. Used inPersistentFSM
on recovery.An initial
currentState -> currentState
notification will be triggered by calling this method.- See Also:
PersistentFSM.receiveRecover()
-
isStateTimerActive
boolean isStateTimerActive()
INTERNAL API, used for testing.- Returns:
- (undocumented)
-
isTimerActive
boolean isTimerActive(java.lang.String name)
Inquire whether the named timer is still active. Returns true unless the timer does not exist, has previously been canceled or if it was a single-shot timer whose message was already received.- Parameters:
name
- (undocumented)- Returns:
- (undocumented)
-
logTermination
void logTermination(PersistentFSM.Reason reason)
By defaultPersistentFSM.Failure
is logged at error level and other reason types are not logged. It is possible to override this behavior.- Parameters:
reason
- (undocumented)
-
makeTransition
void makeTransition(PersistentFSM.State<S,D,E> nextState)
-
nextStateData
D nextStateData()
Return next state data (available in onTransition handlers)- Returns:
- (undocumented)
-
nextState_$eq
void nextState_$eq(PersistentFSM.State<S,D,E> x$1)
-
onTermination
void onTermination(scala.PartialFunction<PersistentFSM.StopEvent<S,D>,scala.runtime.BoxedUnit> terminationHandler)
Set handler which is called upon termination of this FSM actor. Calling this method again will overwrite the previous contents.- Parameters:
terminationHandler
- (undocumented)
-
onTransition
void onTransition(scala.PartialFunction<scala.Tuple2<S,S>,scala.runtime.BoxedUnit> transitionHandler)
Set handler which is called upon each state transition, i.e. not when staying in the same state. This may use the pair extractor defined in the FSM companion object like so:onTransition { case Old -> New => doSomething }
It is also possible to supply a 2-ary function object:
onTransition(handler _) private def handler(from: S, to: S) { ... }
The underscore is unfortunately necessary to enable the nicer syntax shown above (it uses the implicit conversion total2pf under the hood).
Multiple handlers may be installed, and every one of them will be called, not only the first one matching.
- Parameters:
transitionHandler
- (undocumented)
-
postStop
void postStop() throws java.lang.Exception
CallonTermination
hook; if you want to retain this behavior when overriding make sure to callsuper.postStop()
.Please note that this method is called by default from
preRestart()
, so override that one ifonTermination
shall not be called during restart.
-
processEvent
void processEvent(PersistentFSM.Event<D> event, java.lang.Object source)
-
processMsg
void processMsg(java.lang.Object value, java.lang.Object source)
-
receive
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.
-
register
void register(S name, scala.PartialFunction<PersistentFSM.Event<D>,PersistentFSM.State<S,D,E>> function, scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
-
setStateTimeout
void setStateTimeout(S state, scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
Set state timeout explicitly. This method can safely be used from within a state handler.- Parameters:
state
- (undocumented)timeout
- (undocumented)
-
setTimer
void setTimer(java.lang.String name, java.lang.Object msg, scala.concurrent.duration.FiniteDuration timeout, boolean repeat)
Schedule named timer to deliver message after given delay, possibly repeating. Any existing timer with the same name will automatically be canceled before adding the new timer.- Parameters:
name
- identifier to be used with cancelTimer()msg
- message to be deliveredtimeout
- delay of first message delivery and between subsequent messagesrepeat
- send once if false, scheduleAtFixedRate if true
-
setTimer$default$4
boolean setTimer$default$4()
-
startWith
void startWith(S stateName, D stateData, scala.Option<scala.concurrent.duration.FiniteDuration> timeout)
Set initial state. Call this method from the constructor before theinitialize()
method. If different state is needed after a restart this method, followed byinitialize()
, can be used in the actor life cycle hooksActor.preStart()
andActor.postRestart(java.lang.Throwable)
.- Parameters:
stateName
- initial state designatorstateData
- initial state datatimeout
- state timeout for the initial state, overriding the default timeout for that state
-
startWith$default$3
scala.Option<scala.concurrent.duration.FiniteDuration> startWith$default$3()
-
stateData
D stateData()
Return current state data (i.e. object of type D)- Returns:
- (undocumented)
-
stateName
S stateName()
Return current state name (i.e. object of type S)- Returns:
- (undocumented)
-
stateNames
scala.collection.Iterable<S> stateNames()
Return all defined state names- Returns:
- (undocumented)
-
stay
PersistentFSM.State<S,D,E> stay()
Produce "empty" transition descriptor. Return this from a state function when no state change is to be effected.No transition event will be triggered by
stay()
. If you want to trigger an event likeS -> S
foronTransition
to handle usegoto
instead.- Returns:
- descriptor for staying in current state
-
stop
PersistentFSM.State<S,D,E> stop()
Produce change descriptor to stop this FSM actor with reason "Normal".- Returns:
- (undocumented)
-
stop
PersistentFSM.State<S,D,E> stop(PersistentFSM.Reason reason)
Produce change descriptor to stop this FSM actor including specified reason.- Parameters:
reason
- (undocumented)- Returns:
- (undocumented)
-
stop
PersistentFSM.State<S,D,E> stop(PersistentFSM.Reason reason, D stateData)
Produce change descriptor to stop this FSM actor including specified reason.- Parameters:
reason
- (undocumented)stateData
- (undocumented)- Returns:
- (undocumented)
-
super$postStop
void super$postStop()
CallonTermination
hook; if you want to retain this behavior when overriding make sure to callsuper.postStop()
.Please note that this method is called by default from
preRestart()
, so override that one ifonTermination
shall not be called during restart.
-
terminate
void terminate(PersistentFSM.State<S,D,E> nextState)
-
terminateEvent_$eq
void terminateEvent_$eq(scala.PartialFunction<PersistentFSM.StopEvent<S,D>,scala.runtime.BoxedUnit> x$1)
-
timeoutFuture_$eq
void timeoutFuture_$eq(scala.Option<Cancellable> x$1)
-
total2pf
scala.PartialFunction<scala.Tuple2<S,S>,scala.runtime.BoxedUnit> total2pf(scala.Function2<S,S,scala.runtime.BoxedUnit> transitionHandler)
Convenience wrapper for using a total function instead of a partial function literal. To be used with onTransition.- Parameters:
transitionHandler
- (undocumented)- Returns:
- (undocumented)
-
transform
PersistentFSMBase.TransformHelper transform(scala.PartialFunction<PersistentFSM.Event<D>,PersistentFSM.State<S,D,E>> func)
-
transitionEvent_$eq
void transitionEvent_$eq(scala.collection.immutable.List<scala.PartialFunction<scala.Tuple2<S,S>,scala.runtime.BoxedUnit>> x$1)
-
when
void when(S stateName, scala.concurrent.duration.FiniteDuration stateTimeout, scala.PartialFunction<PersistentFSM.Event<D>,PersistentFSM.State<S,D,E>> stateFunction)
Insert a new StateFunction at the end of the processing chain for the given state. If the stateTimeout parameter is set, entering this state without a differing explicit timeout setting will trigger a StateTimeout event; the same is true when using #stay.- Parameters:
stateName
- designator for the statestateTimeout
- default state timeout for this statestateFunction
- partial function describing response to input
-
when$default$2
scala.concurrent.duration.FiniteDuration when$default$2()
-
whenUnhandled
void whenUnhandled(scala.PartialFunction<PersistentFSM.Event<D>,PersistentFSM.State<S,D,E>> stateFunction)
Set handler which is called upon reception of unhandled messages. Calling this method again will overwrite the previous contents.The current state may be queried using
stateName
.
- Parameters:
stateFunction
- (undocumented)
-
-