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

removed deprecation warnings from akka-remote-tests

Browse source
This commit is contained in:
Dario Rexin 2013-04-26 20:54:33 +02:00
parent 4bdfb07653
commit cfb1dfa745
2 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-remote-tests/src/test/scala/akka/remote/testconductor/BarrierSpec.scala
View file

@ -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

2
akka-remote-tests/src/test/scala/akka/remote/testconductor/ControllerSpec.scala
View file

@ -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)