Fixed bunch of stuff based on feedback on pull request.

Moved all cluster config to akka-cluster (and added test).

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
This commit is contained in:
Jonas Bonér 2012-01-31 15:00:46 +01:00
parent 475635fdd0
commit 0b59640820
10 changed files with 133 additions and 90 deletions

View file

@ -0,0 +1,35 @@
/**
* Copyright (C) 2009-2012 Typesafe Inc. <http://www.typesafe.com>
*/
package akka.cluster
import akka.testkit.AkkaSpec
import akka.util.duration._
import akka.util.Duration
@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner])
class ClusterConfigSpec extends AkkaSpec(
"""
akka {
actor {
provider = "akka.remote.RemoteActorRefProvider"
}
}
""") {
"Clustering" must {
"be able to parse generic cluster config elements" in {
val settings = new ClusterSettings(system.settings.config, system.name)
import settings._
FailureDetectorThreshold must be(8)
FailureDetectorMaxSampleSize must be(1000)
SeedNodeConnectionTimeout must be(30 seconds)
MaxTimeToRetryJoiningCluster must be(30 seconds)
InitialDelayForGossip must be(5 seconds)
GossipFrequency must be(1 second)
SeedNodes must be(Set())
}
}
}