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

Hooked the clustering into RemoteServer

Browse source
This commit is contained in:
Viktor Klang 2009-12-12 15:57:06 +01:00
parent 40be6c92d8
commit ddcf294c53
2 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-actors/src/main/scala/nio/Cluster.scala
View file

@ -33,8 +33,8 @@ object Cluster extends Cluster {
def name = impl.map(_.name).getOrElse("No cluster")
def members = impl.map(_.members).getOrElse(Nil)
def registerLocalNode(server : RemoteAddress) : Unit = impl.map(_.registerLocalNode(server))
def deregisterLocalNode(server : RemoteAddress) : Unit = impl.map(_.deregisterLocalNode(server))
def registerLocalNode(hostname : String, port : Int) : Unit = impl.map(_.registerLocalNode(RemoteAddress(hostname,port)))
def deregisterLocalNode(hostname : String, port : Int) : Unit = impl.map(_.deregisterLocalNode(RemoteAddress(hostname,port)))
}
object JGroupsClusterActor {

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

@ -109,11 +109,13 @@ class RemoteServer extends Logging {
bootstrap.setOption("child.connectTimeoutMillis", RemoteServer.CONNECTION_TIMEOUT_MILLIS)
bootstrap.bind(new InetSocketAddress(hostname, port))
isRunning = true
Cluster.registerLocalNode(hostname,port)
}
}
def shutdown = {
bootstrap.releaseExternalResources
Cluster.deregisterLocalNode(hostname,port)
}
}