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