From 9b6aeadf2edd85147f417452395535827c70f010 Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Fri, 31 Aug 2012 10:44:07 +0200 Subject: [PATCH] createRoutees also when initial CurrentClusterState is received, see #2103 --- .../main/scala/akka/cluster/routing/ClusterRouterConfig.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/akka-cluster/src/main/scala/akka/cluster/routing/ClusterRouterConfig.scala b/akka-cluster/src/main/scala/akka/cluster/routing/ClusterRouterConfig.scala index d79bdec56f..ff7875a050 100644 --- 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