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

made StateChangeEvent public. fixes #23072

Browse source
This commit is contained in:
lantz moore 2017-05-31 17:30:18 -07:00
parent ce7a7a2148
commit b4b1e8d7ec
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

@ -152,8 +152,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

@ -274,6 +274,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