review comments (Viktor), see #2376
This commit is contained in:
parent
f05447408c
commit
496fd331db
3 changed files with 5 additions and 5 deletions
|
|
@ -51,7 +51,7 @@ akka {
|
|||
provider = "akka.actor.LocalActorRefProvider"
|
||||
|
||||
# The guardian "/user" will use this subclass of akka.actor.SupervisorStrategyConfigurator
|
||||
# to obtain its supervisorstrategy. Besides the default there is
|
||||
# to obtain its supervisorStrategy. Besides the default there is
|
||||
# akka.actor.StoppingSupervisorStrategy
|
||||
guardian-supervisor-strategy = "akka.actor.DefaultSupervisorStrategy"
|
||||
|
||||
|
|
|
|||
|
|
@ -411,7 +411,7 @@ class LocalActorRefProvider(
|
|||
*/
|
||||
def registerExtraNames(_extras: Map[String, InternalActorRef]): Unit = extraNames ++= _extras
|
||||
|
||||
private lazy val guardianSupervisorStrategyConfigurator =
|
||||
private def guardianSupervisorStrategyConfigurator =
|
||||
dynamicAccess.createInstanceFor[SupervisorStrategyConfigurator](settings.SupervisorStrategyClass, Seq()).fold(throw _, x ⇒ x)
|
||||
|
||||
/**
|
||||
|
|
|
|||
|
|
@ -70,11 +70,11 @@ trait SupervisorStrategyConfigurator {
|
|||
def create(): SupervisorStrategy
|
||||
}
|
||||
|
||||
class DefaultSupervisorStrategy extends SupervisorStrategyConfigurator {
|
||||
final class DefaultSupervisorStrategy extends SupervisorStrategyConfigurator {
|
||||
override def create(): SupervisorStrategy = SupervisorStrategy.defaultStrategy
|
||||
}
|
||||
|
||||
class StoppingSupervisorStrategy extends SupervisorStrategyConfigurator {
|
||||
final class StoppingSupervisorStrategy extends SupervisorStrategyConfigurator {
|
||||
override def create(): SupervisorStrategy = SupervisorStrategy.stoppingStrategy
|
||||
}
|
||||
|
||||
|
|
@ -156,7 +156,7 @@ object SupervisorStrategy extends SupervisorStrategyLowPriorityImplicits {
|
|||
|
||||
/**
|
||||
* This strategy resembles Erlang in that failing children are always
|
||||
* terminated.
|
||||
* terminated (one-for-one).
|
||||
*/
|
||||
final val stoppingStrategy: SupervisorStrategy = {
|
||||
def stoppingDecider: Decider = {
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue