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

Merge pull request #1223 from akka/wip-fish-ignore-patriknw

Browse source 
Use fishForMessage instead of ignoreMsg, see #3116
This commit is contained in:
Roland Kuhn 2013-03-06 00:49:21 -08:00
commit 2444971ade
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")
}