From 3f158385b985f2a0accd82bfc1ea4c690a324cf7 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Bj=C3=B6rn=20Antonsson?= Date: Thu, 30 May 2013 11:55:31 +0200 Subject: [PATCH] Add a barrier in RemoteNodeDeathWatchSpec to compensate for connection time. See #3390 --- .../multi-jvm/scala/akka/remote/RemoteNodeDeathWatchSpec.scala | 3 +++ 1 file changed, 3 insertions(+) diff --git a/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeDeathWatchSpec.scala b/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeDeathWatchSpec.scala index c4dc432c8e..d1575bb2d2 100644 --- a/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeDeathWatchSpec.scala +++ b/akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeDeathWatchSpec.scala @@ -118,6 +118,7 @@ abstract class RemoteNodeDeathWatchSpec watcher ! WatchIt(subject) expectMsg(1 second, Ack) subject ! "hello1" + enterBarrier("hello1-message-sent") enterBarrier("watch-established-1") sleep() @@ -128,6 +129,7 @@ abstract class RemoteNodeDeathWatchSpec val subject = system.actorOf(Props(classOf[ProbeActor], testActor), "subject1") enterBarrier("actors-started-1") + enterBarrier("hello1-message-sent") expectMsg(3 seconds, "hello1") enterBarrier("watch-established-1") @@ -137,6 +139,7 @@ abstract class RemoteNodeDeathWatchSpec runOn(third) { enterBarrier("actors-started-1") + enterBarrier("hello1-message-sent") enterBarrier("watch-established-1") }