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

Use fishForMessage instead of ignoreMsg, see #3116

Browse source 
* ignoreMsg doesn't filter already received messages
This commit is contained in:
Patrik Nordwall 2013-03-06 08:25:15 +01:00
parent 119797bfdd
commit b2bdcfebaf
1 changed files with 6 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

9
akka-contrib/src/multi-jvm/scala/akka/contrib/pattern/ClusterSingletonManagerChaosSpec.scala
View file

@ -114,10 +114,13 @@ class ClusterSingletonManagerChaosSpec extends MultiNodeSpec(ClusterSingletonMan
enterBarrier(leader.name + "-active")
runOn(sortedClusterRoles.filterNot(_ == leader): _*) {
ignoreMsg { case EchoStarted ⇒ true }
echo(leader) ! "hello"
expectMsgType[ActorRef].path.address must be(node(leader).address)
ignoreNoMsg()
fishForMessage() {
case _: ActorRef ⇒ true
case EchoStarted ⇒ false
} match {
case echoRef: ActorRef ⇒ echoRef.path.address must be(node(leader).address)
}
}
enterBarrier(leader.name + "-verified")
}