Added a Akka-Kernel for each Scala-Actor-Type.

joelvim · Dec 26, 2011 · 5fec62f · 5fec62f
1 parent 69c8595
commit 5fec62f
Show file tree

Hide file tree

Showing 3 changed files with 30 additions and 8 deletions.
diff --git a/scala/src/main/scala/AkkaActor.scala b/scala/src/main/scala/AkkaActor.scala
@@ -9,20 +9,13 @@ import akka.util.duration._
 import akka.dispatch._
 
 
-class AkkaActorKernel extends Bootable {
+class ActorKernel extends Bootable {
 	val system = ActorSystem("AkkaTest")
 	val runs = 12000000
 
 	def startup = {
 		val testActor = system.actorOf(Props[CounterActor], "test")
 		runTest(testActor, runs)
-
-		printf("--%n")
-		ag.bett.scala.test.lift.CounterClient.run(runs)
-
-		printf("--%n")
-		ag.bett.scala.test.scala.CounterClient.run(runs)
-
 		shutdown
 		sys.exit(0)
 		//system.eventStream.subscribe(mgmt, classOf[RemoteLifeCycleEvent])

diff --git a/scala/src/main/scala/LiftActor.scala b/scala/src/main/scala/LiftActor.scala
@@ -1,9 +1,24 @@
 package ag.bett.scala.test.lift
 
 import net.liftweb.actor._
+import akka.kernel._
 import scala.compat.Platform
 
 
+class ActorKernel extends Bootable {
+	val runs = 12000000
+
+	def startup = {
+		ag.bett.scala.test.lift.CounterClient.run(runs)
+		shutdown
+	}
+
+	def shutdown = sys.exit(0)
+
+}
+
+
+
 case object GetAndReset
 case class AddCount(number:Long)
 

diff --git a/scala/src/main/scala/ScalaActor.scala b/scala/src/main/scala/ScalaActor.scala
@@ -4,6 +4,20 @@ import scala.actors.Actor
 import scala.actors.Actor._
 import scala.compat.Platform
 import scala.actors.Scheduler
+import akka.kernel._
+
+
+class ActorKernel extends Bootable {
+	val runs = 12000000
+
+	def startup = {
+		ag.bett.scala.test.scala.CounterClient.run(runs)
+		shutdown
+	}
+
+	def shutdown = sys.exit(0)
+
+}
 
 
 case object GetAndReset