Package akka.actor

Class CoordinatedShutdown$

    • Field Detail

      • MODULE$

        public static final CoordinatedShutdown$ MODULE$
        Static reference to the singleton instance of this Scala object.

    • Constructor Detail

      • CoordinatedShutdown$

        public CoordinatedShutdown$()

    • Method Detail

      • PhaseBeforeServiceUnbind

        public java.lang.String PhaseBeforeServiceUnbind()
        The first pre-defined phase that applications can add tasks to. Note that more phases can be added in the application's configuration by overriding this phase with an additional depends-on.

      • PhaseServiceUnbind

        public java.lang.String PhaseServiceUnbind()
        Stop accepting new incoming requests in for example HTTP.

      • PhaseServiceRequestsDone

        public java.lang.String PhaseServiceRequestsDone()
        Wait for requests that are in progress to be completed.

      • PhaseServiceStop

        public java.lang.String PhaseServiceStop()
        Final shutdown of service endpoints.

      • PhaseBeforeClusterShutdown

        public java.lang.String PhaseBeforeClusterShutdown()
        Phase for custom application tasks that are to be run after service shutdown and before cluster shutdown.

      • PhaseClusterShardingShutdownRegion

        public java.lang.String PhaseClusterShardingShutdownRegion()
        Graceful shutdown of the Cluster Sharding regions.

      • PhaseClusterLeave

        public java.lang.String PhaseClusterLeave()
        Emit the leave command for the node that is shutting down.

      • PhaseClusterExiting

        public java.lang.String PhaseClusterExiting()
        Shutdown cluster singletons

      • PhaseClusterExitingDone

        public java.lang.String PhaseClusterExitingDone()
        Wait until exiting has been completed

      • PhaseClusterShutdown

        public java.lang.String PhaseClusterShutdown()
        Shutdown the cluster extension

      • PhaseBeforeActorSystemTerminate

        public java.lang.String PhaseBeforeActorSystemTerminate()
        Phase for custom application tasks that are to be run after cluster shutdown and before ActorSystem termination.

      • PhaseActorSystemTerminate

        public java.lang.String PhaseActorSystemTerminate()
        Last phase. See terminate-actor-system and exit-jvm above. Don't add phases that depends on this phase because the dispatcher and scheduler of the ActorSystem have been shutdown.

      • unknownReason

        public CoordinatedShutdown.Reason unknownReason()
        Java API: The reason for the shutdown was unknown. Needed for backwards compatibility.

      • actorSystemTerminateReason

        public CoordinatedShutdown.Reason actorSystemTerminateReason()
        Java API: The shutdown was initiated by ActorSystem.terminate.

      • jvmExitReason

        public CoordinatedShutdown.Reason jvmExitReason()
        Java API: The shutdown was initiated by a JVM shutdown hook, e.g. triggered by SIGTERM.

      • clusterDowningReason

        public CoordinatedShutdown.Reason clusterDowningReason()
        Java API: The shutdown was initiated by Cluster downing.

      • clusterJoinUnsuccessfulReason

        public CoordinatedShutdown.Reason clusterJoinUnsuccessfulReason()
        Java API: The shutdown was initiated by a failure to join a seed node.

      • incompatibleConfigurationDetectedReason

        public CoordinatedShutdown.Reason incompatibleConfigurationDetectedReason()
        Java API: The shutdown was initiated by a configuration clash within the existing cluster and the joining node

      • clusterLeavingReason

        public CoordinatedShutdown.Reason clusterLeavingReason()
        Java API: The shutdown was initiated by Cluster leaving.

      • get

        public CoordinatedShutdown get​(ActorSystem system)
        Description copied from interface: ExtensionId
        Returns an instance of the extension identified by this ExtensionId instance. Java API For extensions written in Scala that are to be used from Java also, this method should be overridden to get correct return type. 
        
 override def get(system: ActorSystem): TheExtension = super.get(system)

        Specified by:
        get in interface ExtensionId<CoordinatedShutdown>

      • get

        public CoordinatedShutdown get​(ClassicActorSystemProvider system)
        Description copied from interface: ExtensionId
        Returns an instance of the extension identified by this ExtensionId instance. Java API For extensions written in Scala that are to be used from Java also, this method should be overridden to get correct return type. 
        
 override def get(system: ClassicActorSystemProvider): TheExtension = super.get(system)

        Specified by:
        get in interface ExtensionId<CoordinatedShutdown>

      • confWithOverrides

        public com.typesafe.config.Config confWithOverrides​(com.typesafe.config.Config conf,
                                                    scala.Option<CoordinatedShutdown.Reason> reason)

      • phasesFromConfig

        public scala.collection.immutable.Map<java.lang.String,​CoordinatedShutdown.Phase> phasesFromConfig​(com.typesafe.config.Config conf)
        INTERNAL API

      • topologicalSort

        public scala.collection.immutable.List<java.lang.String> topologicalSort​(scala.collection.immutable.Map<java.lang.String,​CoordinatedShutdown.Phase> phases)
        INTERNAL API: https://en.wikipedia.org/wiki/Topological_sorting