diff --git a/scala/src/main/scala/AkkaActor.scala b/scala/src/main/scala/AkkaActor.scala index 69cccc7..a7489d3 100755 --- 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 index cc9d156..e283c6e 100755 --- 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 index e6d92a7..0e54a89 100755 --- 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