From 3e416a4b2c2b9a3dcc3d8723f62b38cf95142166 Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Wed, 23 May 2012 17:39:34 +0200 Subject: [PATCH] Add convergence verification to NodeStartupSpec. See #1948 --- .../src/multi-jvm/scala/akka/cluster/NodeStartupSpec.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/akka-cluster/src/multi-jvm/scala/akka/cluster/NodeStartupSpec.scala b/akka-cluster/src/multi-jvm/scala/akka/cluster/NodeStartupSpec.scala index a0e0e19943..10b5945ee5 100644 --- a/akka-cluster/src/multi-jvm/scala/akka/cluster/NodeStartupSpec.scala +++ b/akka-cluster/src/multi-jvm/scala/akka/cluster/NodeStartupSpec.scala @@ -67,7 +67,8 @@ class NodeStartupSpec extends MultiNodeSpec(NodeStartupMultiJvmSpec) with Implic "join the other node cluster when sending a Join command" taggedAs LongRunningTest in { runOn(second) { // start cluster on second node, and join - Cluster(system) + val secondNode = Cluster(system) + awaitCond(secondNode.convergence.isDefined) } runOn(first) { @@ -78,6 +79,7 @@ class NodeStartupSpec extends MultiNodeSpec(NodeStartupMultiJvmSpec) with Implic } } firstNode.latestGossip.members.size must be(2) + awaitCond(firstNode.convergence.isDefined) } testConductor.enter("done")