akka.cluster
Class FirstSeedNodeProcess

java.lang.Object
  akka.cluster.FirstSeedNodeProcess

All Implemented Interfaces:

Actor, ActorLogging

public final class FirstSeedNodeProcess
extends java.lang.Object
implements Actor, ActorLogging

INTERNAL API.

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.

Nested Class Summary

Nested classes/interfaces inherited from interface akka.actor.Actor

Actor.emptyBehavior$

Constructor Summary

FirstSeedNodeProcess(scala.collection.immutable.IndexedSeq<Address> seedNodes)

Method Summary

Cluster	cluster()
void	postStop() User overridable callback.
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receive() This defines the initial actor behavior, it must return a partial function with the actor logic.
scala.collection.immutable.Set<Address>	remainingSeedNodes()
Cancellable	retryTask()
Address	selfAddress()
scala.concurrent.duration.Deadline	timeout()

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, context, postRestart, preRestart, preStart, self, sender, supervisorStrategy, unhandled

Methods inherited from interface akka.actor.ActorLogging

_log, log

Constructor Detail

FirstSeedNodeProcess

public FirstSeedNodeProcess(scala.collection.immutable.IndexedSeq<Address> seedNodes)

Method Detail

cluster

public Cluster cluster()

selfAddress

public Address selfAddress()

timeout

public scala.concurrent.duration.Deadline timeout()

remainingSeedNodes

public scala.collection.immutable.Set<Address> remainingSeedNodes()

retryTask

public Cancellable retryTask()

postStop

public void postStop()

Description copied from interface: Actor

User overridable callback.

Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.

Specified by:

postStop in interface Actor

receive

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()

Description copied from interface: Actor

This defines the initial actor behavior, it must return a partial function with the actor logic.

Specified by:

receive in interface Actor

Returns:

(undocumented)