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

Added first test of remote actor provisioning using RemoteActorRefProvider.

Browse source 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
This commit is contained in:
Jonas Bonér 2011-09-22 03:37:42 +02:00
parent af49b99d6f
commit 1bfe3716e2
8 changed files with 61 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-remote/src/multi-jvm/scala/akka/cluster/ClusterTestNode.scala → akka-remote/src/multi-jvm/scala/akka/remote/ClusterTestNode.scala
View file

@ -2,7 +2,7 @@
* Copyright (C) 2009-2011 Typesafe Inc. <http://www.typesafe.com>
*/
package akka.cluster
package akka.remote
import org.scalatest.WordSpec
import org.scalatest.matchers.MustMatchers

2
akka-remote/src/multi-jvm/scala/akka/cluster/MasterClusterTestNode.scala → akka-remote/src/multi-jvm/scala/akka/remote/MasterClusterTestNode.scala
View file

@ -2,7 +2,7 @@
* Copyright (C) 2009-2011 Typesafe Inc. <http://www.typesafe.com>
*/
package akka.cluster
package akka.remote
import org.scalatest.WordSpec
import org.scalatest.matchers.MustMatchers

0
akka-remote/src/multi-jvm/scala/akka/cluster/QuietReporter.scala → akka-remote/src/multi-jvm/scala/akka/remote/QuietReporter.scala
View file

4
akka-remote/src/multi-jvm/scala/akka/remote/new_remote_actor/NewRemoteActorMultiJvmNode1.conf Normal file
View file

@ -0,0 +1,4 @@
akka.enabled-modules = ["remote"]
akka.event-handler-level = "DEBUG"
akka.actor.deployment.service-hello.remote.hostname = "localhost"
akka.actor.deployment.service-hello.remote.port = 9991

1
akka-remote/src/multi-jvm/scala/akka/remote/new_remote_actor/NewRemoteActorMultiJvmNode1.opts Normal file
View file

@ -0,0 +1 @@
-Dakka.cluster.nodename=node1 -Dakka.remote.hostname=localhost -Dakka.remote.port=9991

4
akka-remote/src/multi-jvm/scala/akka/remote/new_remote_actor/NewRemoteActorMultiJvmNode2.conf Normal file
View file

@ -0,0 +1,4 @@
akka.enabled-modules = ["remote"]
akka.event-handler-level = "DEBUG"
akka.actor.deployment.service-hello.remote.hostname = "localhost"
akka.actor.deployment.service-hello.remote.port = 9991

1
akka-remote/src/multi-jvm/scala/akka/remote/new_remote_actor/NewRemoteActorMultiJvmNode2.opts Normal file
View file

@ -0,0 +1 @@
-Dakka.cluster.nodename=node2 -Dakka.remote.hostname=localhost -Dakka.remote.port=9992

49
akka-remote/src/multi-jvm/scala/akka/remote/new_remote_actor/NewRemoteActorMultiJvmSpec.scala Normal file
View file

@ -0,0 +1,49 @@
package akka.remote.new_remote_actor
import akka.remote._
import akka.actor.Actor
import akka.config.Config
object NewRemoteActorMultiJvmSpec {
val NrOfNodes = 2
class SomeActor extends Actor with Serializable {
def receive = {
case "identify" ⇒ {
self.reply(Config.nodename)
}
}
}
}
class NewRemoteActorMultiJvmNode1 extends MasterClusterTestNode {
import NewRemoteActorMultiJvmSpec._
val testNodes = NrOfNodes
"___" must {
"___" in {
Remote.start()
Thread.sleep(5000)
}
}
}
class NewRemoteActorMultiJvmNode2 extends ClusterTestNode {
import NewRemoteActorMultiJvmSpec._
"A new remote actor" must {
"be locally instantiated on a remote node and be able to communicate through its RemoteActorRef" in {
Remote.start()
val actor = Actor.actorOf[SomeActor]("service-hello")
val result = (actor ? "identify").get
result must equal("node1")
}
}
}