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

Add a barrier in RemoteNodeDeathWatchSpec to compensate for connection time. See #3390

Browse source
This commit is contained in:
Björn Antonsson 2013-05-30 11:55:31 +02:00
parent c5ce28da7f
commit 3f158385b9
1 changed files with 3 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteNodeDeathWatchSpec.scala
View file

@ -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")
}