diff --git a/akka-samples/akka-sample-camel/src/main/scala/AsyncRouteAndTransform.scala b/akka-samples/akka-sample-camel/src/main/scala/AsyncRouteAndTransform.scala index d424d8486f..85dff9f064 100644 --- a/akka-samples/akka-sample-camel/src/main/scala/AsyncRouteAndTransform.scala +++ b/akka-samples/akka-sample-camel/src/main/scala/AsyncRouteAndTransform.scala @@ -9,8 +9,8 @@ import org.apache.camel.{ Exchange } object AsyncRouteAndTransform extends App { val system = ActorSystem("rewriteAkkaToAKKA") val httpTransformer = system.actorOf(Props[HttpTransformer], "transformer") - val httpProducer = system.actorOf(Props(new HttpProducer(httpTransformer)), "producer") - val httpConsumer = system.actorOf(Props(new HttpConsumer(httpProducer)), "consumer") + val httpProducer = system.actorOf(Props(classOf[HttpProducer], httpTransformer), "producer") + val httpConsumer = system.actorOf(Props(classOf[HttpConsumer], httpProducer), "consumer") } class HttpConsumer(producer: ActorRef) extends Consumer { diff --git a/akka-samples/akka-sample-camel/src/main/scala/SimpleFileConsumer.scala b/akka-samples/akka-sample-camel/src/main/scala/SimpleFileConsumer.scala index 94370d0529..5b96afed2c 100644 --- a/akka-samples/akka-sample-camel/src/main/scala/SimpleFileConsumer.scala +++ b/akka-samples/akka-sample-camel/src/main/scala/SimpleFileConsumer.scala @@ -11,7 +11,7 @@ object SimpleFileConsumer extends App { val tmpDirUri = "file://%s/%s" format (tmpDir, subDir) val system = ActorSystem("consume-files") - val fileConsumer = system.actorOf(Props(new FileConsumer(tmpDirUri)), "fileConsumer") + val fileConsumer = system.actorOf(Props(classOf[FileConsumer], tmpDirUri), "fileConsumer") println(String.format("Put a text file in '%s', the consumer will pick it up!", consumeDir)) } diff --git a/akka-samples/akka-sample-fsm/src/main/scala/DiningHakkersOnBecome.scala b/akka-samples/akka-sample-fsm/src/main/scala/DiningHakkersOnBecome.scala index e5c621d74a..914d37c2fe 100644 --- a/akka-samples/akka-sample-fsm/src/main/scala/DiningHakkersOnBecome.scala +++ b/akka-samples/akka-sample-fsm/src/main/scala/DiningHakkersOnBecome.scala @@ -142,7 +142,7 @@ object DiningHakkers { //Create 5 awesome hakkers and assign them their left and right chopstick val hakkers = for { (name, i) ← List("Ghosh", "Boner", "Klang", "Krasser", "Manie").zipWithIndex - } yield system.actorOf(Props(new Hakker(name, chopsticks(i), chopsticks((i + 1) % 5)))) + } yield system.actorOf(Props(classOf[Hakker], name, chopsticks(i), chopsticks((i + 1) % 5))) //Signal all hakkers that they should start thinking, and watch the show hakkers.foreach(_ ! Think) diff --git a/akka-samples/akka-sample-fsm/src/main/scala/DiningHakkersOnFsm.scala b/akka-samples/akka-sample-fsm/src/main/scala/DiningHakkersOnFsm.scala index fc43289c3c..6c0c8cd459 100644 --- a/akka-samples/akka-sample-fsm/src/main/scala/DiningHakkersOnFsm.scala +++ b/akka-samples/akka-sample-fsm/src/main/scala/DiningHakkersOnFsm.scala @@ -177,7 +177,7 @@ object DiningHakkersOnFsm { // Create 5 awesome fsm hakkers and assign them their left and right chopstick val hakkers = for { (name, i) ← List("Ghosh", "Boner", "Klang", "Krasser", "Manie").zipWithIndex - } yield system.actorOf(Props(new FSMHakker(name, chopsticks(i), chopsticks((i + 1) % 5)))) + } yield system.actorOf(Props(classOf[FSMHakker], name, chopsticks(i), chopsticks((i + 1) % 5))) hakkers.foreach(_ ! Think) } diff --git a/akka-samples/akka-sample-osgi-dining-hakkers/core/src/main/scala/akka/sample/osgi/service/DiningHakkersServiceImpl.scala b/akka-samples/akka-sample-osgi-dining-hakkers/core/src/main/scala/akka/sample/osgi/service/DiningHakkersServiceImpl.scala index 2f29e8b659..b597de8bdc 100644 --- a/akka-samples/akka-sample-osgi-dining-hakkers/core/src/main/scala/akka/sample/osgi/service/DiningHakkersServiceImpl.scala +++ b/akka-samples/akka-sample-osgi-dining-hakkers/core/src/main/scala/akka/sample/osgi/service/DiningHakkersServiceImpl.scala @@ -21,6 +21,6 @@ import akka.sample.osgi.internal.Hakker class DiningHakkersServiceImpl(system: ActorSystem) extends DiningHakkersService { def getHakker(name: String, chairNumber: Int) = { - system.actorOf(Props(new Hakker(name, chairNumber))) + system.actorOf(Props(classOf[Hakker], name, chairNumber)) } } diff --git a/akka-samples/akka-sample-osgi-dining-hakkers/integration-test/src/test/scala/akka/sample/osgi/test/HakkerStatusTest.scala b/akka-samples/akka-sample-osgi-dining-hakkers/integration-test/src/test/scala/akka/sample/osgi/test/HakkerStatusTest.scala index 0d61d98d49..70f761c08a 100644 --- a/akka-samples/akka-sample-osgi-dining-hakkers/integration-test/src/test/scala/akka/sample/osgi/test/HakkerStatusTest.scala +++ b/akka-samples/akka-sample-osgi-dining-hakkers/integration-test/src/test/scala/akka/sample/osgi/test/HakkerStatusTest.scala @@ -93,7 +93,7 @@ java.io.EOFException } } - hakker.tell(Identify, actorSystem.actorOf(Props(new Interrogator()), "Interrogator")) + hakker.tell(Identify, actorSystem.actorOf(Props[Interrogator], "Interrogator")) val (fromHakker, busyWith) = response.poll(5, TimeUnit.SECONDS) println("---------------> %s is busy with %s.".format(fromHakker, busyWith)) diff --git a/akka-samples/akka-sample-remote/src/main/scala/sample/remote/calculator/CreationApplication.scala b/akka-samples/akka-sample-remote/src/main/scala/sample/remote/calculator/CreationApplication.scala index a32c46d600..c6f8cbb6c4 100644 --- a/akka-samples/akka-sample-remote/src/main/scala/sample/remote/calculator/CreationApplication.scala +++ b/akka-samples/akka-sample-remote/src/main/scala/sample/remote/calculator/CreationApplication.scala @@ -18,7 +18,7 @@ class CreationApplication extends Bootable { ActorSystem("RemoteCreation", ConfigFactory.load.getConfig("remotecreation")) val remoteActor = system.actorOf(Props[AdvancedCalculatorActor], name = "advancedCalculator") - val localActor = system.actorOf(Props(new CreationActor(remoteActor)), + val localActor = system.actorOf(Props(classOf[CreationActor], remoteActor), name = "creationActor") def doSomething(op: MathOp): Unit = diff --git a/akka-samples/akka-sample-remote/src/main/scala/sample/remote/calculator/LookupApplication.scala b/akka-samples/akka-sample-remote/src/main/scala/sample/remote/calculator/LookupApplication.scala index a1c21b4f56..86024cc9b9 100644 --- a/akka-samples/akka-sample-remote/src/main/scala/sample/remote/calculator/LookupApplication.scala +++ b/akka-samples/akka-sample-remote/src/main/scala/sample/remote/calculator/LookupApplication.scala @@ -23,7 +23,7 @@ class LookupApplication extends Bootable { ActorSystem("LookupApplication", ConfigFactory.load.getConfig("remotelookup")) val remotePath = "akka.tcp://CalculatorApplication@127.0.0.1:2552/user/simpleCalculator" - val actor = system.actorOf(Props(new LookupActor(remotePath)), "lookupActor") + val actor = system.actorOf(Props(classOf[LookupActor], remotePath), "lookupActor") def doSomething(op: MathOp): Unit = actor ! op