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

Two unrenamed variable references fixed (#23120)

Browse source
This commit is contained in:
Johan Andrén 2017-06-07 18:00:02 +02:00 • committed by GitHub
parent 41098a427f
commit 168b40e40c
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-cluster-tools/src/multi-jvm/scala/akka/cluster/client/ClusterClientSpec.scala
View file

@ -374,10 +374,10 @@ class ClusterClientSpec extends MultiNodeSpec(ClusterClientSpec) with STMultiNod
testConductor.exit(receptionistRoleName, 0).await testConductor.exit(receptionistRoleName, 0).await
remainingServerRoleNames -= receptionistRoleName remainingServerRoleNames -= receptionistRoleName
awaitAssert({ awaitAssert({
c ! ClusterClient.Send("/user/service2", "hi again", localAffinity = true) client ! ClusterClient.Send("/user/service2", "hi again", localAffinity = true)
expectMsgType[Reply](1 second).msg should be("hi again-ack") expectMsgType[Reply](1 second).msg should be("hi again-ack")
}, max = remaining - 3.seconds) }, max = remaining - 3.seconds)
system.stop(c) system.stop(client)
} }
enterBarrier("verifed-3") enterBarrier("verifed-3")
receiveWhile(2 seconds) { receiveWhile(2 seconds) {