diff --git a/akka-persistence/src/main/scala/akka/persistence/fsm/PersistentFSM.scala b/akka-persistence/src/main/scala/akka/persistence/fsm/PersistentFSM.scala index ca9be50ef0..17fcdd48bb 100644 --- a/akka-persistence/src/main/scala/akka/persistence/fsm/PersistentFSM.scala +++ b/akka-persistence/src/main/scala/akka/persistence/fsm/PersistentFSM.scala @@ -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 diff --git a/akka-persistence/src/test/scala/akka/persistence/fsm/PersistentFSMSpec.scala b/akka-persistence/src/test/scala/akka/persistence/fsm/PersistentFSMSpec.scala index 377b2c2b77..a415e84b41 100644 --- a/akka-persistence/src/test/scala/akka/persistence/fsm/PersistentFSMSpec.scala +++ b/akka-persistence/src/test/scala/akka/persistence/fsm/PersistentFSMSpec.scala @@ -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