From c2853f7159ad6b5ece3230340d7d3a28cd427f30 Mon Sep 17 00:00:00 2001 From: Saeed Zarinfam Date: Sat, 14 Feb 2015 20:36:51 +0330 Subject: [PATCH] =doc add props static method to IODocText --- akka-docs/rst/java/code/docs/io/japi/IODocTest.java | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/akka-docs/rst/java/code/docs/io/japi/IODocTest.java b/akka-docs/rst/java/code/docs/io/japi/IODocTest.java index 2a2f884033..9d556860e4 100644 --- a/akka-docs/rst/java/code/docs/io/japi/IODocTest.java +++ b/akka-docs/rst/java/code/docs/io/japi/IODocTest.java @@ -40,6 +40,10 @@ public class IODocTest { public Server(ActorRef manager) { this.manager = manager; } + + public static Props props(ActorRef manager) { + return Props.create(Server.class, manager); + } @Override public void preStart() throws Exception { @@ -90,6 +94,10 @@ public class IODocTest { final InetSocketAddress remote; final ActorRef listener; + + public static Props props(InetSocketAddress remote, ActorRef listener) { + return Props.create(Client.class, remote, listener); + } public Client(InetSocketAddress remote, ActorRef listener) { this.remote = remote; @@ -150,9 +158,9 @@ public class IODocTest { new JavaTestKit(system) { { @SuppressWarnings("unused") - final ActorRef server = system.actorOf(Props.create(Server.class, getRef()), "server1"); + final ActorRef server = system.actorOf(Server.props(getRef()), "server1"); final InetSocketAddress listen = expectMsgClass(Bound.class).localAddress(); - final ActorRef client = system.actorOf(Props.create(Client.class, listen, getRef()), "client1"); + final ActorRef client = system.actorOf(Client.props(listen, getRef()), "client1"); final Connected c1 = expectMsgClass(Connected.class); final Connected c2 = expectMsgClass(Connected.class);