Package akka.cluster
Class FirstSeedNodeProcess
- java.lang.Object
-
- akka.cluster.SeedNodeProcess
-
- akka.cluster.FirstSeedNodeProcess
-
- All Implemented Interfaces:
Actor
public final class FirstSeedNodeProcess extends SeedNodeProcess
INTERNAL API.Used only for the first seed node. Sends InitJoin to all seed nodes (except itself). logInfo("Received InitJoinAck message from [{}] to [{}]", from, selfAddress) 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.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Constructor Summary
Constructors Constructor Description FirstSeedNodeProcess(scala.collection.immutable.IndexedSeq<Address> seedNodes, JoinConfigCompatChecker joinConfigCompatChecker)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
postStop()
User overridable callback.scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receive()
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.scala.collection.immutable.Set<Address>
remainingSeedNodes()
void
remainingSeedNodes_$eq(scala.collection.immutable.Set<Address> x$1)
Cancellable
retryTask()
scala.concurrent.duration.Deadline
timeout()
-
Methods inherited from class akka.cluster.SeedNodeProcess
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, cluster, context, receiveInitJoinAckCompatibleConfig, receiveInitJoinAckIncompatibleConfig, receiveInitJoinAckUncheckedConfig, receiveJoinSeedNode, self, selfAddress
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, preRestart, preStart, sender, supervisorStrategy, unhandled
-
-
-
-
Constructor Detail
-
FirstSeedNodeProcess
public FirstSeedNodeProcess(scala.collection.immutable.IndexedSeq<Address> seedNodes, JoinConfigCompatChecker joinConfigCompatChecker)
-
-
Method Detail
-
postStop
public void postStop()
Description copied from interface:Actor
User overridable callback. Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.
-
receive
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Description copied from interface:Actor
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
-
remainingSeedNodes
public scala.collection.immutable.Set<Address> remainingSeedNodes()
-
remainingSeedNodes_$eq
public void remainingSeedNodes_$eq(scala.collection.immutable.Set<Address> x$1)
-
retryTask
public Cancellable retryTask()
-
timeout
public scala.concurrent.duration.Deadline timeout()
-
-