Fixed broken 'stop' method on RoutedActorRef, now shuts down its connections by sending out a 'Broadcast(PoisonPill)'.

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2011-09-28 17:43:51 +02:00 · 2011-09-28 17:43:51 +02:00 · 08c1e918f4
commit 08c1e918f4
parent 5c49e6dfaa
1 changed files with 1 additions and 1 deletions
--- a/akka-actor/src/main/scala/akka/routing/Routing.scala
+++ b/akka-actor/src/main/scala/akka/routing/Routing.scala
@ -240,7 +240,7 @@ private[akka] class RoutedActorRef(val routedProps: RoutedProps, val address: St
    synchronized {
      if (running) {
        running = false
-        postMessageToMailbox(RemoteActorSystemMessage.Stop, None)
+        router.route(Routing.Broadcast(PoisonPill))(Some(this))
      }
    }
  }