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
All Methods Instance Methods Concrete Methods 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 asforward
.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 aAbstractActor.ActorContext
, which is the Java API of the actor context.- Specified by:
akka$actor$Actor$_setter_$context_$eq
in interfaceActor
-
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 interfaceActor
-
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 asforward
.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 aAbstractActor.ActorContext
, which is the Java API of the actor context.
-
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 anIncompatibleConfig
. After sending JoinTo(address),FirstSeedNodeProcess
callscontext.stop(self)
,JoinSeedNodeProcess
callscontext.become(done)
.- Parameters:
joinTo
- the address to join toorigin
- theInitJoinAck
senderbehavior
- onJoinTo
being sent, if defined,context.become
is called, otherwisecontext.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 sendInitJoin
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
-
selfAddress
public Address selfAddress()
-
-