Package akka.cluster

Class FirstSeedNodeProcess

  • All Implemented Interfaces:

    public final class FirstSeedNodeProcess
    extends SeedNodeProcess

    Used only for the first seed node. Sends InitJoin to all seed nodes (except itself). logInfo("Received InitJoinAck message from [{}] to [{}]", from, selfAddress) 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.

    • Constructor Detail

      • FirstSeedNodeProcess

        public FirstSeedNodeProcess​(scala.collection.immutable.IndexedSeq<Address> seedNodes,
                                    JoinConfigCompatChecker joinConfigCompatChecker)
    • Method Detail

      • postStop

        public void postStop()
        Description copied from interface: Actor
        User overridable callback.

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

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive()
        Description copied from interface: Actor
        Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
      • remainingSeedNodes

        public scala.collection.immutable.Set<Address> remainingSeedNodes()
      • remainingSeedNodes_$eq

        public void remainingSeedNodes_$eq​(scala.collection.immutable.Set<Address> x$1)
      • timeout

        public scala.concurrent.duration.Deadline timeout()