From 5ee25d9d40b26a526cc78c0ad58f1258c8bc2da8 Mon Sep 17 00:00:00 2001 From: ortigali Date: Thu, 26 Jan 2017 19:11:08 +0500 Subject: [PATCH] customise test for race between GetState and persistAsync handler #22052 --- .../src/test/scala/akka/persistence/PersistentActorSpec.scala | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/akka-persistence/src/test/scala/akka/persistence/PersistentActorSpec.scala b/akka-persistence/src/test/scala/akka/persistence/PersistentActorSpec.scala index 1f1e76c41b..eb16fd1659 100644 --- a/akka-persistence/src/test/scala/akka/persistence/PersistentActorSpec.scala +++ b/akka-persistence/src/test/scala/akka/persistence/PersistentActorSpec.scala @@ -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"))