Как сделать пользовательское выключение на SIGTERM с помощью Akka?

Question

По умолчанию Akka выключает актерскую систему (ы), когда получает SIGTERM. Как я могу переопределить это поведение, чтобы выполнить свою пользовательскую логику выключения, прежде чем выключать систему akka? У меня уже есть эта логика, реализованная в актерах, используя специальные грациозные сообщения остановки - мне просто нужно вызвать эту логику при получении SIGTERM.

Или мне нужно использовать другой способ отключения приложения? Это также вариант.

Answer 1

Вы можете просто использовать sys.shutdownHookThread так:

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

Answer 2

ли это нужным: 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.