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

Reduce exposure of ActorContext to RouteeProvider

Browse source 
* Introduced RouterContext which is a subset of
  ActorContext that makes sense for RouteeProvider
  to use.
* It's not possible (without major rethinking) to
  create routees by sending message to the Router
  actor because we rely on immediate return of ActorRef
This commit is contained in:
Patrik Nordwall 2012-08-30 13:12:23 +02:00
parent 39a71e50d6
commit fd847535d4
3 changed files with 32 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -8,7 +8,6 @@ import scala.collection.immutable.SortedSet
import com.typesafe.config.ConfigFactory
import akka.ConfigurationException
import akka.actor.Actor
import akka.actor.ActorContext
import akka.actor.ActorRef
import akka.actor.ActorSystemImpl
import akka.actor.Address
@ -31,6 +30,7 @@ import akka.cluster.ClusterScope
import akka.routing.RoundRobinRouter
import akka.routing.Destination
import java.lang.IllegalStateException
import akka.routing.RouterContext
/**
* [[akka.routing.RouterConfig]] implementation for deployment on cluster nodes.
@ -40,7 +40,7 @@ import java.lang.IllegalStateException
*/
case class ClusterRouterConfig(local: RouterConfig, totalInstances: Int, maxInstancesPerNode: Int) extends RouterConfig {
override def createRouteeProvider(context: ActorContext, routeeProps: Props) =
override def createRouteeProvider(context: RouterContext, routeeProps: Props) =
new ClusterRouteeProvider(context, routeeProps, resizer, totalInstances, maxInstancesPerNode)
override def createRoute(routeeProvider: RouteeProvider): Route = {
@ -73,7 +73,7 @@ case class ClusterRouterConfig(local: RouterConfig, totalInstances: Int, maxInst
* Deploys new routees on the cluster nodes.
*/
private[akka] class ClusterRouteeProvider(
_context: ActorContext,
_context: RouterContext,
_routeeProps: Props,
_resizer: Option[Resizer],
totalInstances: Int,