From cada63a03f134e2d0fe474ea3f24e5dc363ef71d Mon Sep 17 00:00:00 2001 From: Viktor Klang Date: Sun, 7 Mar 2010 23:23:09 +0100 Subject: [PATCH] Making it possile to turn cluster on/off in config --- .../src/main/scala/remote/BootableRemoteActorService.scala | 5 ++++- config/akka-reference.conf | 2 +- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/akka-core/src/main/scala/remote/BootableRemoteActorService.scala b/akka-core/src/main/scala/remote/BootableRemoteActorService.scala index 61c920c0af..e200db9619 100644 --- a/akka-core/src/main/scala/remote/BootableRemoteActorService.scala +++ b/akka-core/src/main/scala/remote/BootableRemoteActorService.scala @@ -25,7 +25,10 @@ trait BootableRemoteActorService extends Bootable with Logging { abstract override def onLoad = { if(config.getBool("akka.remote.server.service", true)){ super.onLoad //Initialize BootableActorLoaderService before remote service - Cluster.start(self.applicationLoader) + + if(config.getBool("akka.remote.cluster.service", true)) + Cluster.start(self.applicationLoader) + log.info("Initializing Remote Actors Service...") startRemoteService log.info("Remote Actors Service initialized!") diff --git a/config/akka-reference.conf b/config/akka-reference.conf index 14933a3cac..66afda9d30 100644 --- a/config/akka-reference.conf +++ b/config/akka-reference.conf @@ -49,7 +49,7 @@ zlib-compression-level = 6 # Options: 0-9 (1 being fastest and 9 being the most compressed), default is 6 - service = on # FIXME add 'service = on' for + service = on name = "default" # The name of the cluster actor = "se.scalablesolutions.akka.remote.JGroupsClusterActor" # FQN of an implementation of ClusterActor serializer = "se.scalablesolutions.akka.serialization.Serializer$Java" # FQN of the serializer class