From b4b1e8d7ec31e72c6804c491efab9062e4ec7ef2 Mon Sep 17 00:00:00 2001 From: lantz moore Date: Wed, 31 May 2017 17:30:18 -0700 Subject: [PATCH] made StateChangeEvent public. fixes #23072 --- .../main/scala/akka/persistence/fsm/PersistentFSM.scala | 3 +-- .../scala/akka/persistence/fsm/PersistentFSMSpec.scala | 7 +++++++ 2 files changed, 8 insertions(+), 2 deletions(-) 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 4046687f74..2c6ec4a3b2 100644 --- a/akka-persistence/src/main/scala/akka/persistence/fsm/PersistentFSM.scala +++ b/akka-persistence/src/main/scala/akka/persistence/fsm/PersistentFSM.scala @@ -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 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 83cf191a3f..cdd6db4b4c 100644 --- a/akka-persistence/src/test/scala/akka/persistence/fsm/PersistentFSMSpec.scala +++ b/akka-persistence/src/test/scala/akka/persistence/fsm/PersistentFSMSpec.scala @@ -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