Package akka.cluster

Class SeedNodeProcess

java.lang.Object

akka.cluster.SeedNodeProcess

All Implemented Interfaces:

Actor

Direct Known Subclasses:

FirstSeedNodeProcess, JoinSeedNodeProcess

public abstract class SeedNodeProcess
extends java.lang.Object
implements Actor

INTERNAL API.

Nested Class Summary

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

Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor	Description
SeedNodeProcess(JoinConfigCompatChecker joinConfigCompatChecker)

Method Summary

Modifier and Type	Method	Description
protected void	akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)	Scala API: Stores the context for this actor, including self, and sender.
protected void	akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)	The 'self' field holds the ActorRef for this actor.
Cluster	cluster()
ActorContext	context()	Scala API: Stores the context for this actor, including self, and sender.
void	receiveInitJoinAckCompatibleConfig(Address joinTo, ActorRef origin, InternalClusterAction.CompatibleConfig configCheck, scala.Option<scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>> behavior)
void	receiveInitJoinAckIncompatibleConfig(Address joinTo, ActorRef origin, scala.Option<scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>> behavior)	INTERNAL API.
void	receiveInitJoinAckUncheckedConfig(Address joinTo, ActorRef origin, scala.Option<scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>> behavior)
void	receiveJoinSeedNode(scala.collection.immutable.Set<Address> seedNodes)	INTERNAL API.
ActorRef	self()	The 'self' field holds the ActorRef for this actor.
Address	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, postStop, preRestart, preStart, receive, sender, supervisorStrategy, unhandled

Constructor Detail

SeedNodeProcess

public SeedNodeProcess(JoinConfigCompatChecker joinConfigCompatChecker)

Method Detail

akka$actor$Actor$_setter_$context_$eq

protected void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)

Description copied from interface: Actor

Scala API: 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 AbstractActor.ActorContext, which is the Java API of the actor context.

Specified by:

akka$actor$Actor$_setter_$context_$eq in interface Actor

akka$actor$Actor$_setter_$self_$eq

protected final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)

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:

akka$actor$Actor$_setter_$self_$eq in interface Actor

cluster

public Cluster cluster()

context

public ActorContext context()

Description copied from interface: Actor

Scala API: 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 AbstractActor.ActorContext, which is the Java API of the actor context.

Specified by:

context in interface Actor

receiveInitJoinAckCompatibleConfig

public final void receiveInitJoinAckCompatibleConfig(Address joinTo,
                                                     ActorRef origin,
                                                     InternalClusterAction.CompatibleConfig configCheck,
                                                     scala.Option<scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>> behavior)

receiveInitJoinAckIncompatibleConfig

public final void receiveInitJoinAckIncompatibleConfig(Address joinTo,
                                                       ActorRef origin,
                                                       scala.Option<scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>> behavior)

INTERNAL API. Received first InitJoinAck reply with an IncompatibleConfig. After sending JoinTo(address), FirstSeedNodeProcess calls context.stop(self), JoinSeedNodeProcess calls context.become(done).

Parameters:

joinTo - the address to join to

origin - the InitJoinAck sender

behavior - on JoinTo being sent, if defined, context.become is called, otherwise context.stop.

receiveInitJoinAckUncheckedConfig

public final void receiveInitJoinAckUncheckedConfig(Address joinTo,
                                                    ActorRef origin,
                                                    scala.Option<scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>> behavior)

receiveJoinSeedNode

public final void receiveJoinSeedNode(scala.collection.immutable.Set<Address> seedNodes)

INTERNAL API.

Parameters:

seedNodes - the remaining (if first seed process) otherwise the other seed nodes to send InitJoin commands to

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

selfAddress

public Address selfAddress()