diff --git a/akka-docs/java/code/akka/docs/transactor/TransactorDocTest.java b/akka-docs/java/code/akka/docs/transactor/TransactorDocTest.java index 7ad2c62cc0..e6b45f675c 100644 --- a/akka-docs/java/code/akka/docs/transactor/TransactorDocTest.java +++ b/akka-docs/java/code/akka/docs/transactor/TransactorDocTest.java @@ -23,8 +23,8 @@ public class TransactorDocTest { //#coordinated-example ActorSystem system = ActorSystem.create("CoordinatedExample"); - ActorRef counter1 = system.actorOf(new Props().withCreator(CoordinatedCounter.class)); - ActorRef counter2 = system.actorOf(new Props().withCreator(CoordinatedCounter.class)); + ActorRef counter1 = system.actorOf(new Props(CoordinatedCounter.class)); + ActorRef counter2 = system.actorOf(new Props(CoordinatedCounter.class)); Timeout timeout = new Timeout(5, SECONDS); @@ -46,7 +46,7 @@ public class TransactorDocTest { //#create-coordinated ActorSystem system = ActorSystem.create("CoordinatedApi"); - ActorRef actor = system.actorOf(new Props().withCreator(Coordinator.class)); + ActorRef actor = system.actorOf(new Props(Coordinator.class)); //#send-coordinated actor.tell(new Coordinated(new Message(), timeout)); @@ -64,7 +64,7 @@ public class TransactorDocTest { @Test public void counterTransactor() { ActorSystem system = ActorSystem.create("CounterTransactor"); - ActorRef counter = system.actorOf(new Props().withCreator(Counter.class)); + ActorRef counter = system.actorOf(new Props(Counter.class)); Timeout timeout = new Timeout(5, SECONDS); Coordinated coordinated = new Coordinated(timeout); @@ -80,8 +80,8 @@ public class TransactorDocTest { @Test public void friendlyCounterTransactor() { ActorSystem system = ActorSystem.create("FriendlyCounterTransactor"); - ActorRef friend = system.actorOf(new Props().withCreator(Counter.class)); - ActorRef friendlyCounter = system.actorOf(new Props().withCreator(FriendlyCounter.class)); + ActorRef friend = system.actorOf(new Props(Counter.class)); + ActorRef friendlyCounter = system.actorOf(new Props(FriendlyCounter.class)); Timeout timeout = new Timeout(5, SECONDS); Coordinated coordinated = new Coordinated(timeout); diff --git a/akka-transactor/src/test/java/akka/transactor/UntypedCoordinatedIncrementTest.java b/akka-transactor/src/test/java/akka/transactor/UntypedCoordinatedIncrementTest.java index 591b8f2a48..7fce881b2c 100644 --- a/akka-transactor/src/test/java/akka/transactor/UntypedCoordinatedIncrementTest.java +++ b/akka-transactor/src/test/java/akka/transactor/UntypedCoordinatedIncrementTest.java @@ -60,14 +60,14 @@ public class UntypedCoordinatedIncrementTest { counters = new ArrayList(); for (int i = 1; i <= numCounters; i++) { final String name = "counter" + i; - ActorRef counter = system.actorOf(new Props().withCreator(new UntypedActorFactory() { + ActorRef counter = system.actorOf(new Props(new UntypedActorFactory() { public UntypedActor create() { return new UntypedCoordinatedCounter(name); } })); counters.add(counter); } - failer = system.actorOf(new Props().withCreator(UntypedFailer.class)); + failer = system.actorOf(new Props(UntypedFailer.class)); } @Test diff --git a/akka-transactor/src/test/java/akka/transactor/UntypedTransactorTest.java b/akka-transactor/src/test/java/akka/transactor/UntypedTransactorTest.java index aa83fe0d4f..9e2cf39f8d 100644 --- a/akka-transactor/src/test/java/akka/transactor/UntypedTransactorTest.java +++ b/akka-transactor/src/test/java/akka/transactor/UntypedTransactorTest.java @@ -61,14 +61,14 @@ public class UntypedTransactorTest { counters = new ArrayList(); for (int i = 1; i <= numCounters; i++) { final String name = "counter" + i; - ActorRef counter = system.actorOf(new Props().withCreator(new UntypedActorFactory() { + ActorRef counter = system.actorOf(new Props(new UntypedActorFactory() { public UntypedActor create() { return new UntypedCounter(name); } })); counters.add(counter); } - failer = system.actorOf(new Props().withCreator(UntypedFailer.class)); + failer = system.actorOf(new Props(UntypedFailer.class)); } @Test