From 2e537af78a97a089dd6f87652bc4df59e892021e Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Mon, 10 Sep 2012 13:13:59 +0200 Subject: [PATCH] attachChild in ClusterRouteeProvider also, see #2485 --- .../main/scala/akka/cluster/routing/ClusterRouterConfig.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/akka-cluster/src/main/scala/akka/cluster/routing/ClusterRouterConfig.scala b/akka-cluster/src/main/scala/akka/cluster/routing/ClusterRouterConfig.scala index fa45341519..dc9ee4ac0e 100644 --- a/akka-cluster/src/main/scala/akka/cluster/routing/ClusterRouterConfig.scala +++ b/akka-cluster/src/main/scala/akka/cluster/routing/ClusterRouterConfig.scala @@ -30,6 +30,7 @@ import akka.routing.Router import akka.routing.RouterConfig import akka.routing.RemoteRouterConfig import akka.actor.RootActorPath +import akka.actor.ActorCell /** * [[akka.routing.RouterConfig]] implementation for deployment on cluster nodes. @@ -121,8 +122,7 @@ private[akka] class ClusterRouteeProvider( } else { val name = "c" + childNameCounter.incrementAndGet val deploy = Deploy("", ConfigFactory.empty(), routeeProps.routerConfig, RemoteScope(target)) - impl.provider.actorOf(impl, routeeProps, context.self.asInstanceOf[InternalActorRef], context.self.path / name, - systemService = false, Some(deploy), lookupDeploy = false, async = false) + context.asInstanceOf[ActorCell].attachChild(routeeProps.withDeploy(deploy), name, systemService = false) } // must register each one, since registered routees are used in selectDeploymentTarget registerRoutees(Some(ref))