raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

enhanced the RemoteServer API

Browse source
This commit is contained in:
jboner 2009-10-11 11:21:12 +02:00
parent 44556dc57d
commit de982e7fe8
1 changed files with 5 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-actors/src/main/scala/nio/RemoteServer.scala
View file

@ -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)