From ae3b4ab8b7f594e81f297bae5ed9bf038ee19d94 Mon Sep 17 00:00:00 2001 From: Patrik Nordwall Date: Thu, 30 Aug 2012 13:41:01 +0200 Subject: [PATCH] Test cluster router deployment config --- .../akka/cluster/ClusterDeployerSpec.scala | 52 +++++++++++++++++++ 1 file changed, 52 insertions(+) create mode 100644 akka-cluster/src/test/scala/akka/cluster/ClusterDeployerSpec.scala diff --git a/akka-cluster/src/test/scala/akka/cluster/ClusterDeployerSpec.scala b/akka-cluster/src/test/scala/akka/cluster/ClusterDeployerSpec.scala new file mode 100644 index 0000000000..60aeec3013 --- /dev/null +++ b/akka-cluster/src/test/scala/akka/cluster/ClusterDeployerSpec.scala @@ -0,0 +1,52 @@ +/** + * Copyright (C) 2009-2012 Typesafe Inc. + */ +package akka.cluster + +import akka.testkit._ +import akka.actor._ +import akka.routing._ +import com.typesafe.config._ +import akka.cluster.routing.ClusterRouterConfig + +object ClusterDeployerSpec { + val deployerConf = ConfigFactory.parseString(""" + akka.actor.provider = "akka.cluster.ClusterActorRefProvider" + akka.actor.deployment { + /user/service2 { + router = round-robin + nr-of-instances = 20 + cluster.enabled = on + cluster.max-nr-of-instances-per-node = 3 + } + } + akka.remote.netty.port = 0 + """, ConfigParseOptions.defaults) + + class RecipeActor extends Actor { + def receive = { case _ ⇒ } + } + +} + +@org.junit.runner.RunWith(classOf[org.scalatest.junit.JUnitRunner]) +class ClusterDeployerSpec extends AkkaSpec(ClusterDeployerSpec.deployerConf) { + + "A RemoteDeployer" must { + + "be able to parse 'akka.actor.deployment._' with specified cluster settings" in { + val service = "/user/service2" + val deployment = system.asInstanceOf[ActorSystemImpl].provider.deployer.lookup(service.split("/").drop(1)) + deployment must not be (None) + + deployment must be(Some( + Deploy( + service, + deployment.get.config, + ClusterRouterConfig(RoundRobinRouter(20), 20, 3), + ClusterScope))) + } + + } + +} \ No newline at end of file