diff --git a/akka-cluster-tools/src/multi-jvm/scala/akka/cluster/client/ClusterClientSpec.scala b/akka-cluster-tools/src/multi-jvm/scala/akka/cluster/client/ClusterClientSpec.scala index 579348bc6a..8f578f42fd 100644 --- a/akka-cluster-tools/src/multi-jvm/scala/akka/cluster/client/ClusterClientSpec.scala +++ b/akka-cluster-tools/src/multi-jvm/scala/akka/cluster/client/ClusterClientSpec.scala @@ -374,10 +374,10 @@ class ClusterClientSpec extends MultiNodeSpec(ClusterClientSpec) with STMultiNod testConductor.exit(receptionistRoleName, 0).await remainingServerRoleNames -= receptionistRoleName 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") }, max = remaining - 3.seconds) - system.stop(c) + system.stop(client) } enterBarrier("verifed-3") receiveWhile(2 seconds) {