82 lines
No EOL
3.6 KiB
Scala
82 lines
No EOL
3.6 KiB
Scala
/**
|
|
* Copyright (C) 2009-2011 Typesafe Inc. <http://www.typesafe.com>
|
|
*/
|
|
package akka.remote
|
|
|
|
import com.typesafe.config.Config
|
|
import akka.util.Duration
|
|
import java.util.concurrent.TimeUnit.MILLISECONDS
|
|
import java.net.InetAddress
|
|
import akka.config.ConfigurationException
|
|
import com.eaio.uuid.UUID
|
|
import akka.actor._
|
|
import scala.collection.JavaConverters._
|
|
|
|
class RemoteSettings(val config: Config, val systemName: String) extends Extension {
|
|
|
|
import config._
|
|
|
|
val RemoteTransport = getString("akka.remote.transport")
|
|
val FailureDetectorThreshold = getInt("akka.remote.failure-detector.threshold")
|
|
val FailureDetectorMaxSampleSize = getInt("akka.remote.failure-detector.max-sample-size")
|
|
val ShouldCompressData = config.getBoolean("akka.remote.use-compression")
|
|
val RemoteSystemDaemonAckTimeout = Duration(config.getMilliseconds("akka.remote.remote-daemon-ack-timeout"), MILLISECONDS)
|
|
val InitalDelayForGossip = Duration(config.getMilliseconds("akka.remote.gossip.initialDelay"), MILLISECONDS)
|
|
val GossipFrequency = Duration(config.getMilliseconds("akka.remote.gossip.frequency"), MILLISECONDS)
|
|
|
|
// TODO cluster config will go into akka-cluster/reference.conf when we enable that module
|
|
val ClusterName = getString("akka.cluster.name")
|
|
val SeedNodes = Set.empty[RemoteNettyAddress] ++ getStringList("akka.cluster.seed-nodes").asScala.collect {
|
|
case RemoteAddressExtractor(addr) ⇒ addr.transport
|
|
}
|
|
|
|
val NodeName: String = config.getString("akka.cluster.nodename") match {
|
|
case "" ⇒ "undefined"
|
|
case value ⇒ value
|
|
}
|
|
|
|
val serverSettings = new RemoteServerSettings
|
|
val clientSettings = new RemoteClientSettings
|
|
|
|
class RemoteClientSettings {
|
|
val SecureCookie: Option[String] = config.getString("akka.remote.secure-cookie") match {
|
|
case "" ⇒ None
|
|
case cookie ⇒ Some(cookie)
|
|
}
|
|
|
|
val ReconnectionTimeWindow = Duration(config.getMilliseconds("akka.remote.client.reconnection-time-window"), MILLISECONDS)
|
|
val ReadTimeout = Duration(config.getMilliseconds("akka.remote.client.read-timeout"), MILLISECONDS)
|
|
val ReconnectDelay = Duration(config.getMilliseconds("akka.remote.client.reconnect-delay"), MILLISECONDS)
|
|
val MessageFrameSize = config.getBytes("akka.remote.client.message-frame-size").toInt
|
|
}
|
|
|
|
class RemoteServerSettings {
|
|
import scala.collection.JavaConverters._
|
|
val MessageFrameSize = config.getBytes("akka.remote.server.message-frame-size").toInt
|
|
val SecureCookie: Option[String] = config.getString("akka.remote.secure-cookie") match {
|
|
case "" ⇒ None
|
|
case cookie ⇒ Some(cookie)
|
|
}
|
|
val RequireCookie = {
|
|
val requireCookie = config.getBoolean("akka.remote.server.require-cookie")
|
|
if (requireCookie && SecureCookie.isEmpty) throw new ConfigurationException(
|
|
"Configuration option 'akka.remote.server.require-cookie' is turned on but no secure cookie is defined in 'akka.remote.secure-cookie'.")
|
|
requireCookie
|
|
}
|
|
|
|
val UsePassiveConnections = config.getBoolean("akka.remote.use-passive-connections")
|
|
|
|
val UntrustedMode = config.getBoolean("akka.remote.server.untrusted-mode")
|
|
val Hostname = config.getString("akka.remote.server.hostname") match {
|
|
case "" ⇒ InetAddress.getLocalHost.getHostAddress
|
|
case value ⇒ value
|
|
}
|
|
val Port = config.getInt("akka.remote.server.port")
|
|
val ConnectionTimeout = Duration(config.getMilliseconds("akka.remote.server.connection-timeout"), MILLISECONDS)
|
|
|
|
val Backlog = config.getInt("akka.remote.server.backlog")
|
|
|
|
// TODO handle the system name right and move this to config file syntax
|
|
val URI = "akka://sys@" + Hostname + ":" + Port
|
|
}
|
|
} |