Jak wykonać niestandardowe wyłączenie urządzenia SIGTERM za pomocą Akki?

Question

Domyślnie Akka wyłącza system (-y) aktorów po otrzymaniu SIGTERM. Jak mogę przesłonić to zachowanie, aby wykonać niestandardową logikę zamykania przed zamknięciem systemu akka? Mam już tę logikę zaimplementowaną u aktorów, używając specjalnych wdzięcznych komunikatów stopu - po prostu muszę wywołać tę logikę, gdy otrzymam SIGTERM.

Czy muszę użyć innego sposobu wyłączenia aplikacji? To także opcja.

Answer 1

można po prostu użyć sys.shutdownHookThread takiego:

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

Answer 2

Czy to pasuje: 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.