Come eseguire l'arresto personalizzato su SIGTERM con Akka?

Question

Per impostazione predefinita, Akka arresta il/i sistema/i dell'attore/i quando riceve uno SIGTERM. Come posso ignorare questo comportamento per eseguire la mia logica di arresto personalizzato prima di arrestare il sistema akka? Ho già implementato questa logica negli attori, usando speciali messaggi di interruzione aggraziati - Ho solo bisogno di invocare quella logica quando viene ricevuto il SIGTERM.

Oppure devo utilizzare un altro modo per arrestare l'applicazione? Anche questa è un'opzione.

Answer 1

Si può semplicemente utilizzare sys.shutdownHookThread come questo:

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

Answer 2

Sarebbe questo 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.