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

customise test for race between GetState and persistAsync handler #22052

Browse source
This commit is contained in:
ortigali 2017-01-26 19:11:08 +05:00
parent 844a474654
commit 5ee25d9d40
1 changed files with 1 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -1154,9 +1154,7 @@ abstract class PersistentActorSpec(config: Config) extends PersistenceSpec(confi
"be able to persist events that happen during recovery" in {
val persistentActor = namedPersistentActor[PersistInRecovery]
persistentActor ! GetState
expectMsg(List("a-1", "a-2", "rc-1", "rc-2"))
persistentActor ! GetState
expectMsg(List("a-1", "a-2", "rc-1", "rc-2", "rc-3"))
expectMsgAnyOf(List("a-1", "a-2", "rc-1", "rc-2"), List("a-1", "a-2", "rc-1", "rc-2", "rc-3"))
persistentActor ! Cmd("invalid")
persistentActor ! GetState
expectMsg(List("a-1", "a-2", "rc-1", "rc-2", "rc-3", "invalid"))