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

Cleaned up cluster instantiation

Browse source
This commit is contained in:
Viktor Klang 2010-02-02 23:23:37 +01:00
parent 4764e1c39a
commit db446cc609
1 changed files with 15 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

24
akka-core/src/main/scala/remote/Cluster.scala
View file

@ -199,17 +199,23 @@ abstract class BasicClusterActor extends ClusterActor {
* Loads a specified ClusterActor and delegates to that instance.
*/
object Cluster extends Cluster with Logging {
private[remote] val clusterActor: Option[ClusterActor] = {
val name = config.getString("akka.remote.cluster.actor","not defined")
try {
val a = Class.forName(name).newInstance.asInstanceOf[ClusterActor]
private[remote] val actorName = config.getString("akka.remote.cluster.actor")
private[remote] val clusterActor = createClusterActor
private[remote] def createClusterActor : Option[ClusterActor] = {
try {
actorName map { s =>
val a = Class.forName(s).newInstance.asInstanceOf[ClusterActor]
a.start
Some(a)
}
catch {
case e => log.error(e,"Couldn't load Cluster provider: [%s]",name)
None
a
}
}
catch {
case e => log.error(e,"Couldn't load Cluster provider: [%s]",actorName.getOrElse(""))
None
}
}
private[remote] val supervisor: Option[Supervisor] = if (clusterActor.isDefined) {