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

Added configuration based routing for local ActorRefProvider, also moved replication-factor from 'cluster' section to generic section of config'

Browse source 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
This commit is contained in:
Jonas Bonér 2011-09-28 14:50:09 +02:00
parent 8297f459e3
commit 9721dbc50a
6 changed files with 68 additions and 56 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala
View file

@ -31,7 +31,6 @@ class RemoteActorRefProvider extends ActorRefProvider {
import java.util.concurrent.ConcurrentHashMap
import akka.dispatch.Promise
// FIXME who evicts this registry, and when? Should it be used instead of ActorRegistry?
private val actors = new ConcurrentHashMap[String, Promise[Option[ActorRef]]]
private val failureDetector = new BannagePeriodFailureDetector(timeToBan = 60 seconds) // FIXME make timeToBan configurable
@ -45,7 +44,7 @@ class RemoteActorRefProvider extends ActorRefProvider {
if (oldFuture eq null) { // we won the race -- create the actor and resolve the future
val actor = try {
Deployer.lookupDeploymentFor(address) match {
case Some(Deploy(_, _, router, _, RemoteScope(host, port))) ⇒
case Some(Deploy(_, _, router, nrOfInstances, _, RemoteScope(host, port))) ⇒
// FIXME create RoutedActorRef if 'router' is specified
val serverAddress = Remote.address