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

=clu #3519 Cluster router should use provided supervisor strategy

Browse source
This commit is contained in:
Endre Sándor Varga 2013-07-24 12:45:47 +02:00
parent ae801199a5
commit 12989a9078
2 changed files with 54 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

@ -52,7 +52,7 @@ final case class ClusterRouterConfig(local: RouterConfig, settings: ClusterRoute
}: Route) orElse localRoute
}
override def createActor(): Router = new ClusterRouterActor
override def createActor(): Router = new ClusterRouterActor(local.supervisorStrategy)
override def supervisorStrategy: SupervisorStrategy = local.supervisorStrategy
@ -269,7 +269,7 @@ private[akka] class ClusterRouteeProvider(
* INTERNAL API
* The router actor, subscribes to cluster events.
*/
private[akka] class ClusterRouterActor extends Router {
private[akka] class ClusterRouterActor(override val supervisorStrategy: SupervisorStrategy) extends Router {
// re-subscribe when restart
override def preStart(): Unit = {