Package akka.cluster

Class SeedNodeProcess

    • 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
        Parameters:
        x$1 - (undocumented)
      • 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
        Parameters:
        x$1 - (undocumented)
      • 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
        Returns:
        (undocumented)
      • 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
        Returns:
        (undocumented)
      • selfAddress

        public Address selfAddress()