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

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