diff --git a/akka-actors/src/main/scala/nio/RemoteServer.scala b/akka-actors/src/main/scala/nio/RemoteServer.scala index ccb7661674..c8a5bbdd9d 100644 --- a/akka-actors/src/main/scala/nio/RemoteServer.scala +++ b/akka-actors/src/main/scala/nio/RemoteServer.scala @@ -49,10 +49,14 @@ object RemoteServer extends Logging { private val bootstrap = new ServerBootstrap(factory) - def start(loader: Option[ClassLoader]) = synchronized { + def start: Unit = start(None) + def start(loader: Option[ClassLoader]): Unit = start(HOSTNAME, PORT) + def start(hostname: String, port: Int): Unit = start(hostname, port, None) + def start(hostname: String, port: Int, loader: Option[ClassLoader]): Unit = synchronized { if (!isRunning) { log.info("Starting remote server at [%s:%s]", HOSTNAME, PORT) bootstrap.setPipelineFactory(new RemoteServerPipelineFactory(name, loader)) + // FIXME make these RemoteServer options configurable bootstrap.setOption("child.tcpNoDelay", true) bootstrap.setOption("child.keepAlive", true) bootstrap.setOption("child.reuseAddress", true)