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

2609 Typo in method name for ClusterRouteeProvider

Browse source
This commit is contained in:
Helena Edelson 2012-10-10 09:58:18 -06:00
parent 6f70624ddd
commit 24c115547d
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

@ -196,7 +196,7 @@ private[akka] class ClusterRouteeProvider(
private def selectDeploymentTarget: Option[Address] = {
val currentRoutees = routees
val currentNodes = availbleNodes
val currentNodes = availableNodes
if (currentNodes.isEmpty || currentRoutees.size >= settings.totalInstances) {
None
} else {
@ -222,7 +222,7 @@ private[akka] class ClusterRouteeProvider(
case a ⇒ a
}
private[routing] def availbleNodes: SortedSet[Address] = {
private[routing] def availableNodes: SortedSet[Address] = {
import Member.addressOrdering
val currentNodes = nodes
if (currentNodes.isEmpty && settings.allowLocalRoutees)