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

Fixed cluster

Browse source
This commit is contained in:
Viktor Klang 2010-05-20 20:35:36 +02:00
parent a162f4705d
commit 37b8524ded
1 changed files with 6 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -249,9 +249,11 @@ object Cluster extends Cluster with Logging {
try {
name map {
fqn =>
val a = Class.forName(fqn).newInstance.asInstanceOf[ClusterActor]
a setSerializer serializer
Actor.actorOf(a)
Actor.actorOf({
val a = Class.forName(fqn).newInstance.asInstanceOf[ClusterActor]
a setSerializer serializer
a
})
}
}
catch {
@ -288,7 +290,7 @@ object Cluster extends Cluster with Logging {
actorRef <- createClusterActor(serializerClassLoader getOrElse getClass.getClassLoader)
sup <- createSupervisor(actorRef)
} {
clusterActorRef = Some(actorRef)
clusterActorRef = Some(actorRef.start)
clusterActor = Some(actorRef.actor.asInstanceOf[ClusterActor])
sup.start
}