Merge pull request #1727 from akka/wip-3583-timer-auto-down-patriknw

!act #3583 Timer based auto-down
This commit is contained in:
Patrik Nordwall 2013-09-29 22:39:33 -07:00
commit 565957cdb8
27 changed files with 355 additions and 450 deletions

View file

@ -100,6 +100,9 @@ class Cluster(val system: ExtendedActorSystem) extends Extension {
logInfo("Starting up...")
if (settings.AutoDown)
log.warning("[akka.cluster.auto-down] setting is replaced by [akka.cluster.auto-down-unreachable-after]")
val failureDetector: FailureDetectorRegistry[Address] = {
def createFailureDetector(): FailureDetector =
FailureDetectorLoader.load(settings.FailureDetectorImplementationClass, settings.FailureDetectorConfig, system)