raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

=per #19688 [2.4.1][PersistentFSM] getting StateTimeout for state wit… (#20266)

Browse source 
* =per #19688 [2.4.1][PersistentFSM] getting StateTimeout for state without timeout after restart

* Added deprecation warning
This commit is contained in:
Leonid Bakaleynik 2016-04-20 16:22:18 +03:00 • committed by Patrik Nordwall
parent 3d9065309c
commit e0af113f17
2 changed files with 5 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

10
akka-persistence/src/main/scala/akka/persistence/fsm/PersistentFSMBase.scala
View file

@ -301,15 +301,15 @@ trait PersistentFSMBase[S, D, E] extends Actor with Listeners with ActorLogging
handleEvent = stateFunction orElse handleEventDefault handleEvent = stateFunction orElse handleEventDefault
/** /**
* Verify existence of initial state and setup timers. This should be the * Verify existence of initial state and setup timers. Used in [[akka.persistence.fsm.PersistentFSM]]
* last call within the constructor, or [[akka.actor.Actor#preStart]] and * on recovery.
* [[akka.actor.Actor#postRestart]].
* *
* An initial `currentState -> currentState` notification will be triggered by calling this method. * An initial `currentState -> currentState` notification will be triggered by calling this method.
* *
* @see [[#startWith]] * @see [[akka.persistence.fsm.PersistentFSM#receiveRecover]]
*/ */
final def initialize(): Unit = @deprecated("Removed from API, called internally", "2.4.5")
private[akka] final def initialize(): Unit =
if (currentState != null) makeTransition(currentState) if (currentState != null) makeTransition(currentState)
else throw new IllegalStateException("You must call `startWith` before calling `initialize`") else throw new IllegalStateException("You must call `startWith` before calling `initialize`")

2
akka-persistence/src/test/java/akka/persistence/fsm/AbstractPersistentFSMTest.java
View file

@ -568,8 +568,6 @@ public class AbstractPersistentFSMTest extends JUnitSuite {
matchEvent(Leave.class, (event, data) -> stop()) matchEvent(Leave.class, (event, data) -> stop())
.event(GetCurrentCart.class, (event, data) -> stay().replying(data)) .event(GetCurrentCart.class, (event, data) -> stay().replying(data))
); );
initialize();
//#customer-fsm-body //#customer-fsm-body
} }