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

attachChild in ClusterRouteeProvider also, see #2485

Browse source
This commit is contained in:
Patrik Nordwall 2012-09-10 13:13:59 +02:00
parent f746115c4d
commit 2e537af78a
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-cluster/src/main/scala/akka/cluster/routing/ClusterRouterConfig.scala
View file

@ -30,6 +30,7 @@ import akka.routing.Router
import akka.routing.RouterConfig import akka.routing.RouterConfig
import akka.routing.RemoteRouterConfig import akka.routing.RemoteRouterConfig
import akka.actor.RootActorPath import akka.actor.RootActorPath
import akka.actor.ActorCell
/** /**
* [[akka.routing.RouterConfig]] implementation for deployment on cluster nodes. * [[akka.routing.RouterConfig]] implementation for deployment on cluster nodes.
@ -121,8 +122,7 @@ private[akka] class ClusterRouteeProvider(
} else { } else {
val name = "c" + childNameCounter.incrementAndGet val name = "c" + childNameCounter.incrementAndGet
val deploy = Deploy("", ConfigFactory.empty(), routeeProps.routerConfig, RemoteScope(target)) val deploy = Deploy("", ConfigFactory.empty(), routeeProps.routerConfig, RemoteScope(target))
impl.provider.actorOf(impl, routeeProps, context.self.asInstanceOf[InternalActorRef], context.self.path / name, context.asInstanceOf[ActorCell].attachChild(routeeProps.withDeploy(deploy), name, systemService = false)
systemService = false, Some(deploy), lookupDeploy = false, async = false)
} }
// must register each one, since registered routees are used in selectDeploymentTarget // must register each one, since registered routees are used in selectDeploymentTarget
registerRoutees(Some(ref)) registerRoutees(Some(ref))