fix-up Cluster’s complaint for too slow Scheduler, see #2904
This commit is contained in:
parent
ebbfd77d50
commit
5dacfaeb38
1 changed files with 1 additions and 1 deletions
|
|
@ -93,7 +93,7 @@ class Cluster(val system: ExtendedActorSystem) extends Extension {
|
||||||
import scala.collection.JavaConverters._
|
import scala.collection.JavaConverters._
|
||||||
log.info("Using a dedicated scheduler for cluster. Default scheduler can be used if configured " +
|
log.info("Using a dedicated scheduler for cluster. Default scheduler can be used if configured " +
|
||||||
"with 'akka.scheduler.tick-duration' [{} ms] <= 'akka.cluster.scheduler.tick-duration' [{} ms].",
|
"with 'akka.scheduler.tick-duration' [{} ms] <= 'akka.cluster.scheduler.tick-duration' [{} ms].",
|
||||||
1000 / system.scheduler.maxFrequency, SchedulerTickDuration.toMillis)
|
(1000 / system.scheduler.maxFrequency).toInt, SchedulerTickDuration.toMillis)
|
||||||
new DefaultScheduler(
|
new DefaultScheduler(
|
||||||
ConfigFactory.parseString(s"akka.scheduler.tick-duration=${SchedulerTickDuration.toMillis}ms").withFallback(
|
ConfigFactory.parseString(s"akka.scheduler.tick-duration=${SchedulerTickDuration.toMillis}ms").withFallback(
|
||||||
system.settings.config),
|
system.settings.config),
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue