Permalink
Browse files

Multi-JVM Stop actors before we shut down nodes to avoid warning mess…

…ages.
  • Loading branch information...
1 parent 3223a94 commit b922fa0b06a22498bd6fc1f43d78a0a286d74380 @bantonsson bantonsson committed Mar 20, 2012
@@ -55,8 +55,10 @@ class DirectRoutedRemoteActorMultiJvmNode2 extends AkkaRemoteSpec(nodeConfigs(1)
Await.result(actor ? "identify", timeout.duration).asInstanceOf[ActorRef].path.address.hostPort must equal(akkaSpec(0))
+ // shut down the actor before we let the other node(s) shut down so we don't try to send
+ // "Terminate" to a shut down node
+ system.stop(actor)
barrier("done")
}
}
}
-
@@ -55,6 +55,9 @@ class NewRemoteActorMultiJvmNode2 extends AkkaRemoteSpec(NewRemoteActorMultiJvmS
val actor = system.actorOf(Props[SomeActor], "service-hello")
Await.result(actor ? "identify", timeout.duration).asInstanceOf[ActorRef].path.address.hostPort must equal(akkaSpec(0))
+ // shut down the actor before we let the other node(s) shut down so we don't try to send
+ // "Terminate" to a shut down node
+ system.stop(actor)
barrier("done")
}
}
@@ -100,6 +100,9 @@ class RandomRoutedRemoteActorMultiJvmNode4 extends AkkaRemoteSpec(RandomRoutedRe
barrier("end")
replies.values foreach { _ must be > (0) }
+ // shut down the actor before we let the other node(s) shut down so we don't try to send
+ // "Terminate" to a shut down node
+ system.stop(actor)
barrier("done")
}
}
@@ -102,6 +102,9 @@ class RoundRobinRoutedRemoteActorMultiJvmNode4 extends AkkaRemoteSpec(RoundRobin
barrier("end")
replies.values foreach { _ must be(10) }
+ // shut down the actor before we let the other node(s) shut down so we don't try to send
+ // "Terminate" to a shut down node
+ system.stop(actor)
barrier("done")
}
}

0 comments on commit b922fa0

Please sign in to comment.