createRoutees also when initial CurrentClusterState is received, see #2103

2012-08-31 10:44:07 +02:00 · 2012-08-31 10:44:07 +02:00 · 9b6aeadf2e
commit 9b6aeadf2e
parent c84e05a779
1 changed files with 1 additions and 0 deletions
--- a/akka-cluster/src/main/scala/akka/cluster/routing/ClusterRouterConfig.scala
+++ b/akka-cluster/src/main/scala/akka/cluster/routing/ClusterRouterConfig.scala
@ -169,6 +169,7 @@ private[akka] class ClusterRouterActor extends Router {
    case s: CurrentClusterState ⇒
      import Member.addressOrdering
      routeeProvider.upNodes = s.members.collect { case m if m.status == MemberStatus.Up ⇒ m.address }
+      routeeProvider.createRoutees()

    case MemberUp(m) ⇒
      routeeProvider.upNodes += m.address