public final class FirstSeedNodeProcess
extends java.lang.Object
implements akka.actor.Actor, akka.actor.ActorLogging
Used only for the first seed node. Sends InitJoin to all seed nodes (except itself). If other seed nodes are not part of the cluster yet they will reply with InitJoinNack or not respond at all and then the first seed node will join itself to initialize the new cluster. When the first seed node is restarted, and some other seed node is part of the cluster it will reply with InitJoinAck and then the first seed node will join that other seed node to join existing cluster.
Constructor and Description |
---|
FirstSeedNodeProcess(scala.collection.immutable.IndexedSeq<akka.actor.Address> seedNodes) |
Modifier and Type | Method and Description |
---|---|
Cluster |
cluster() |
void |
postStop() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
scala.collection.immutable.Set<akka.actor.Address> |
remainingSeedNodes() |
akka.actor.Cancellable |
retryTask() |
akka.actor.Address |
selfAddress() |
scala.concurrent.duration.Deadline |
timeout() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public FirstSeedNodeProcess(scala.collection.immutable.IndexedSeq<akka.actor.Address> seedNodes)
public Cluster cluster()
public akka.actor.Address selfAddress()
public scala.concurrent.duration.Deadline timeout()
public scala.collection.immutable.Set<akka.actor.Address> remainingSeedNodes()
public akka.actor.Cancellable retryTask()
public void postStop()
postStop
in interface akka.actor.Actor
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor