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

2609 Fixed more 'available' typos in ClusterRouteeProvider

Browse source
This commit is contained in:
Helena Edelson 2012-10-10 10:05:41 -06:00
parent 24c115547d
commit 61481da6cd
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -236,11 +236,11 @@ private[akka] class ClusterRouteeProvider(
private[routing] var nodes: SortedSet[Address] = {
import Member.addressOrdering
cluster.readView.members.collect {
case m if isAvailble(m) ⇒ m.address
case m if isAvailable(m) ⇒ m.address
}
}
private[routing] def isAvailble(m: Member): Boolean = {
private[routing] def isAvailable(m: Member): Boolean = {
m.status == MemberStatus.Up && (settings.allowLocalRoutees || m.address != cluster.selfAddress)
}
@ -271,10 +271,10 @@ private[akka] class ClusterRouterActor extends Router {
override def routerReceive: Receive = {
case s: CurrentClusterState ⇒
import Member.addressOrdering
routeeProvider.nodes = s.members.collect { case m if routeeProvider.isAvailble(m) ⇒ m.address }
routeeProvider.nodes = s.members.collect { case m if routeeProvider.isAvailable(m) ⇒ m.address }
routeeProvider.createRoutees()
case m: MemberEvent if routeeProvider.isAvailble(m.member) ⇒
case m: MemberEvent if routeeProvider.isAvailable(m.member) ⇒
routeeProvider.nodes += m.member.address
// createRoutees will create routees based on
// totalInstances and maxInstancesPerNode