diff --git a/akka-cluster/src/main/scala/akka/cluster/ClusterDaemon.scala b/akka-cluster/src/main/scala/akka/cluster/ClusterDaemon.scala index 70a6477087..2e1f5f761e 100644 --- a/akka-cluster/src/main/scala/akka/cluster/ClusterDaemon.scala +++ b/akka-cluster/src/main/scala/akka/cluster/ClusterDaemon.scala @@ -850,17 +850,14 @@ private[cluster] final class JoinSeedNodeProcess(environment: ClusterEnvironment context.setReceiveTimeout(environment.settings.SeedNodeTimeout) - override def preStart(): Unit = { - self ! JoinSeedNode - } + override def preStart(): Unit = self ! JoinSeedNode def receive = { case JoinSeedNode ⇒ // send InitJoin to all seed nodes (except myself) - val seedRefs = environment.seedNodes.collect { + environment.seedNodes.collect { case a if a != selfAddress ⇒ context.system.actorFor(context.parent.path.toStringWithAddress(a)) - } - seedRefs foreach { _ ! InitJoin } + } foreach { _ ! InitJoin } case InitJoinAck(address) ⇒ // first InitJoinAck reply context.parent ! JoinTo(address)