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

=per #16528 improved persistent actor stash test coverage

Browse source 
Existing tests covering stashin in PersistentActor moved to separate
test class.

New async write journal for tests SteppingInmemJournal allows to
control the async journal operations tightly from a test. Each journal
operation requires a token which the test then can wait for consumption of.
This commit is contained in:
Johan Andrén 2015-09-15 09:24:46 +02:00
parent c57b4e24c8
commit 4d95fd569d
3 changed files with 325 additions and 78 deletions
Download patch file Download diff file Expand all files Collapse all files

78
akka-persistence/src/test/scala/akka/persistence/PersistentActorSpec.scala
View file

@ -188,35 +188,6 @@ object PersistentActorSpec {
}
}
class UserStashPersistentActor(name: String) extends ExamplePersistentActor(name) {
var stashed = false
val receiveCommand: Receive = {
case Cmd("a") ⇒ if (!stashed) { stash(); stashed = true } else sender() ! "a"
case Cmd("b") ⇒ persist(Evt("b"))(evt ⇒ sender() ! evt.data)
case Cmd("c") ⇒ unstashAll(); sender() ! "c"
}
}
class UserStashManyPersistentActor(name: String) extends ExamplePersistentActor(name) {
val receiveCommand: Receive = commonBehavior orElse {
case Cmd("a") ⇒ persist(Evt("a")) { evt ⇒
updateState(evt)
context.become(processC)
}
case Cmd("b-1") ⇒ persist(Evt("b-1"))(updateState)
case Cmd("b-2") ⇒ persist(Evt("b-2"))(updateState)
}
val processC: Receive = {
case Cmd("c") ⇒
persist(Evt("c")) { evt ⇒
updateState(evt)
context.unbecome()
}
unstashAll()
case other ⇒ stash()
}
}
class AsyncPersistPersistentActor(name: String) extends ExamplePersistentActor(name) {
var counter = 0
@ -346,27 +317,6 @@ object PersistentActorSpec {
}
}
class UserStashFailurePersistentActor(name: String) extends ExamplePersistentActor(name) {
val receiveCommand: Receive = commonBehavior orElse {
case Cmd(data) ⇒
if (data == "b-2") throw new TestException("boom")
persist(Evt(data)) { event ⇒
updateState(event)
if (data == "a") context.become(otherCommandHandler)
}
}
val otherCommandHandler: Receive = {
case Cmd("c") ⇒
persist(Evt("c")) { event ⇒
updateState(event)
context.unbecome()
}
unstashAll()
case other ⇒ stash()
}
}
class AnyValEventPersistentActor(name: String) extends ExamplePersistentActor(name) {
val receiveCommand: Receive = {
case Cmd("a") ⇒ persist(5)(evt ⇒ sender() ! evt)
@ -776,34 +726,6 @@ abstract class PersistentActorSpec(config: Config) extends PersistenceSpec(confi
persistentActor ! Cmd("a")
expectMsg("a")
}
"support user stash operations" in {
val persistentActor = namedPersistentActor[UserStashPersistentActor]
persistentActor ! Cmd("a")
persistentActor ! Cmd("b")
persistentActor ! Cmd("c")
expectMsg("b")
expectMsg("c")
expectMsg("a")
}
"support user stash operations with several stashed messages" in {
val persistentActor = namedPersistentActor[UserStashManyPersistentActor]
val n = 10
val cmds = 1 to n flatMap (_ ⇒ List(Cmd("a"), Cmd("b-1"), Cmd("b-2"), Cmd("c")))
val evts = 1 to n flatMap (_ ⇒ List("a", "c", "b-1", "b-2"))
cmds foreach (persistentActor ! _)
persistentActor ! GetState
expectMsg((List("a-1", "a-2") ++ evts))
}
"support user stash operations under failures" in {
val persistentActor = namedPersistentActor[UserStashFailurePersistentActor]
val bs = 1 to 10 map ("b-" + _)
persistentActor ! Cmd("a")
bs foreach (persistentActor ! Cmd(_))
persistentActor ! Cmd("c")
persistentActor ! GetState
expectMsg(List("a-1", "a-2", "a", "c") ++ bs.filter(_ != "b-2"))
}
"be able to persist events that extend AnyVal" in {
val persistentActor = namedPersistentActor[AnyValEventPersistentActor]
persistentActor ! Cmd("a")