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$, Actor.ignoringBehavior$

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Cluster	cluster()
ActorContext	context() Stores the context for this actor, including self, and sender.
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()
ActorRef	self() The 'self' field holds the ActorRef for this actor.
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, postRestart, preRestart, preStart, sender, supervisorStrategy, unhandled

Methods inherited from interface akka.actor.ActorLogging

log

Constructor Detail

FirstSeedNodeProcess

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

Method Detail

context

public ActorContext context()

Description copied from interface: Actor

Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

ActorContext is the Scala API. getContext returns a UntypedActorContext, which is the Java API of the actor context.

Specified by:

context in interface Actor

Returns:

(undocumented)

self

public final ActorRef self()

Description copied from interface: Actor

The 'self' field holds the ActorRef for this actor.

Can be used to send messages to itself:

 self ! message
 

Specified by:

self in interface Actor

Returns:

(undocumented)

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)