Added failure detection to clustered and local routing.

Still not turned on since need deployment config support first. Also refactored current routing quite a lot. Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2011-08-30 14:31:59 +02:00 · 2011-08-30 14:31:59 +02:00 · e0385e5203
commit e0385e5203
parent aabb5ff7ad
11 changed files with 525 additions and 411 deletions
--- a/akka-tutorials/akka-tutorial-second/src/main/scala/Pi.scala
+++ b/akka-tutorials/akka-tutorial-second/src/main/scala/Pi.scala
@ -56,7 +56,7 @@ object Pi extends App {
    val router = Routing.actorOf(
      RoutedProps.apply()
        .withConnections(workers)
-        .withRoundRobinRouter()
+        .withRoundRobinRouter
        .withDeployId("pi"))

    // phase 1, can accept a Calculate message