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

Incorporate review comments, see #2270

Browse source
This commit is contained in:
Patrik Nordwall 2012-08-15 17:31:36 +02:00
parent 963c9a4e3e
commit 4501120ff3
1 changed files with 3 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

9
akka-cluster/src/main/scala/akka/cluster/ClusterDaemon.scala
View file

@ -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)