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

Merge pull request #23074 from mizerlou/persistent-fsm-state-name-extractor

Browse source 
PersistentFSM.StateChangeEvent extractor
This commit is contained in:
Patrik Nordwall 2017-06-19 13:51:37 +02:00 • committed by GitHub
commit 26243a1af7
2 changed files with 8 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-persistence/src/main/scala/akka/persistence/fsm/PersistentFSM.scala
View file

@ -194,8 +194,7 @@ object PersistentFSM {
* @param stateIdentifier FSM state identifier
* @param timeout FSM state timeout
*/
@InternalApi
private[persistence] case class StateChangeEvent(stateIdentifier: String, timeout: Option[FiniteDuration]) extends PersistentFsmEvent
case class StateChangeEvent(stateIdentifier: String, timeout: Option[FiniteDuration]) extends PersistentFsmEvent
/**
* FSM state and data snapshot

7
akka-persistence/src/test/scala/akka/persistence/fsm/PersistentFSMSpec.scala
View file

@ -278,6 +278,13 @@ abstract class PersistentFSMSpec(config: Config) extends PersistenceSpec(config)
expectTerminated(persistentEventsStreamer)
}
"can extract state name" in {
StateChangeEvent("xxx", None) match {
case StateChangeEvent(name, _) ⇒ name should equal("xxx")
case _ ⇒ fail("unable to extract state name")
}
}
"persist snapshot" in {
val persistenceId = name