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