Wie kann man benutzerdefiniertes Herunterfahren auf SIGTERM mit Akka durchführen?

Question

Standardmäßig beendet Akka die Actor-Systeme, wenn es eine SIGTERM empfängt. Wie kann ich dieses Verhalten außer Kraft setzen, um meine benutzerdefinierte Abschaltlogik vor dem Herunterfahren des akka-Systems auszuführen? Ich habe diese Logik bereits in den Aktoren implementiert, indem ich spezielle anmutige Stop-Nachrichten verwende - ich muss diese Logik nur aufrufen, wenn die SIGTERM empfangen wird.

Oder muss ich eine andere Möglichkeit zum Herunterfahren der Anwendung verwenden? Das ist auch eine Option.

Answer 1

Sie können nur sys.shutdownHookThread wie folgt verwenden:

def main(args: Array[String]) { 
    ... initialization code ... 
    sys.shutdownHookThread { 
    println "Shutting down ..." 
    shutdownHandler ! DoSomething 
    } 
} 

Answer 2

Würde dies fit: http://doc.akka.io/api/akka/2.1.0/#akka.actor.ActorSystem

 
abstract def 
registerOnTermination(code: Runnable): Unit 
Register a block of code (callback) to run after ActorSystem.shutdown has been issued and all actors in this actor system have been stopped. Multiple code blocks may be registered by calling this method multiple times. The callbacks will be run sequentially in reverse order of registration, i.e. last registration is run first. 
Exceptions thrown 
a 
RejectedExecutionException if the System has already shut down or if shutdown has been initiated. 


abstract def 
registerOnTermination[T](code: ⇒ T): Unit 
Register a block of code (callback) to run after ActorSystem.shutdown has been issued and all actors in this actor system have been stopped. Multiple code blocks may be registered by calling this method multiple times. The callbacks will be run sequentially in reverse order of registration, i.e. last registration is run first. 
Exceptions thrown 
a 
RejectedExecutionException if the System has already shut down or if shutdown has been initiated.