From cfb1dfa7451bf27565a6c63991be5b10eae7f8ef Mon Sep 17 00:00:00 2001 From: Dario Rexin Date: Fri, 26 Apr 2013 20:54:33 +0200 Subject: [PATCH] removed deprecation warnings from akka-remote-tests --- .../src/test/scala/akka/remote/testconductor/BarrierSpec.scala | 2 +- .../test/scala/akka/remote/testconductor/ControllerSpec.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/akka-remote-tests/src/test/scala/akka/remote/testconductor/BarrierSpec.scala b/akka-remote-tests/src/test/scala/akka/remote/testconductor/BarrierSpec.scala index 696a29f24b..fe24dc1da1 100644 --- a/akka-remote-tests/src/test/scala/akka/remote/testconductor/BarrierSpec.scala +++ b/akka-remote-tests/src/test/scala/akka/remote/testconductor/BarrierSpec.scala @@ -523,7 +523,7 @@ class BarrierSpec extends AkkaSpec(BarrierSpec.config) with ImplicitSender { private def withController(participants: Int)(f: (ActorRef) ⇒ Unit): Unit = { system.actorOf(Props(new Actor { - val controller = context.actorOf(Props(new Controller(participants, new InetSocketAddress(InetAddress.getLocalHost, 0)))) + val controller = context.actorOf(Props(classOf[Controller], participants, new InetSocketAddress(InetAddress.getLocalHost, 0))) controller ! GetSockAddr override def supervisorStrategy = OneForOneStrategy() { case x ⇒ testActor ! Failed(controller, x); SupervisorStrategy.Restart diff --git a/akka-remote-tests/src/test/scala/akka/remote/testconductor/ControllerSpec.scala b/akka-remote-tests/src/test/scala/akka/remote/testconductor/ControllerSpec.scala index 742ef36c9c..2e0ee878ee 100644 --- a/akka-remote-tests/src/test/scala/akka/remote/testconductor/ControllerSpec.scala +++ b/akka-remote-tests/src/test/scala/akka/remote/testconductor/ControllerSpec.scala @@ -27,7 +27,7 @@ class ControllerSpec extends AkkaSpec(ControllerSpec.config) with ImplicitSender "A Controller" must { "publish its nodes" in { - val c = system.actorOf(Props(new Controller(1, new InetSocketAddress(InetAddress.getLocalHost, 0)))) + val c = system.actorOf(Props(classOf[Controller], 1, new InetSocketAddress(InetAddress.getLocalHost, 0))) c ! NodeInfo(A, AddressFromURIString("akka://sys"), testActor) expectMsg(ToClient(Done)) c ! NodeInfo(B, AddressFromURIString("akka://sys"), testActor)