Package org.apache.pekko.actor

Class CoordinatedShutdown$

java.lang.Object
org.apache.pekko.actor.CoordinatedShutdown$
All Implemented Interfaces:
ExtensionId<CoordinatedShutdown>, ExtensionIdProvider
public class CoordinatedShutdown$ extends Object implements ExtensionId<CoordinatedShutdown>, ExtensionIdProvider

  • Field Details

    • MODULE$

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

  • Constructor Details

    • CoordinatedShutdown$

      public CoordinatedShutdown$()

  • Method Details

    • PhaseBeforeServiceUnbind

      public String PhaseBeforeServiceUnbind()

    • PhaseServiceUnbind

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

    • PhaseServiceRequestsDone

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

    • PhaseServiceStop

      public String PhaseServiceStop()
      Final shutdown of service endpoints.

    • PhaseBeforeClusterShutdown

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

    • PhaseClusterShardingShutdownRegion

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

    • PhaseClusterLeave

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

    • PhaseClusterExiting

      public String PhaseClusterExiting()
      Shutdown cluster singletons

    • PhaseClusterExitingDone

      public String PhaseClusterExitingDone()
      Wait until exiting has been completed

    • PhaseClusterShutdown

      public String PhaseClusterShutdown()
      Shutdown the cluster extension

    • PhaseBeforeActorSystemTerminate

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

    • PhaseActorSystemTerminate

      public 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()

    • actorSystemTerminateReason

      public CoordinatedShutdown.Reason actorSystemTerminateReason()

    • jvmExitReason

      public CoordinatedShutdown.Reason jvmExitReason()

    • clusterDowningReason

      public CoordinatedShutdown.Reason clusterDowningReason()

    • clusterJoinUnsuccessfulReason

      public CoordinatedShutdown.Reason clusterJoinUnsuccessfulReason()

    • incompatibleConfigurationDetectedReason

      public CoordinatedShutdown.Reason incompatibleConfigurationDetectedReason()

    • clusterLeavingReason

      public CoordinatedShutdown.Reason clusterLeavingReason()

    • 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>

    • lookup

      public CoordinatedShutdown$ lookup()
      Description copied from interface: ExtensionIdProvider
      Returns the canonical ExtensionId for this Extension
      Specified by:
      lookup in interface ExtensionIdProvider

    • createExtension

      public CoordinatedShutdown createExtension(ExtendedActorSystem system)
      Description copied from interface: ExtensionId
      Is used by Pekko to instantiate the Extension identified by this ExtensionId, internal use only.
      Specified by:
      createExtension in interface ExtensionId<CoordinatedShutdown>