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

Create timeouts from java without using durations

Browse source
This commit is contained in:
Peter Vlugter 2011-12-22 12:12:41 +13:00
parent 4661145881
commit 9b58ecece7
4 changed files with 8 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

3
akka-docs/java/code/akka/docs/agent/AgentDocTest.java
View file

@ -23,7 +23,6 @@ import akka.japi.Function;
//#import-function //#import-function
//#import-timeout //#import-timeout
import akka.util.Duration;
import akka.util.Timeout; import akka.util.Timeout;
import static java.util.concurrent.TimeUnit.SECONDS; import static java.util.concurrent.TimeUnit.SECONDS;
//#import-timeout //#import-timeout
@ -86,7 +85,7 @@ public class AgentDocTest {
//#send-off //#send-off
//#read-await //#read-await
Integer result = agent.await(new Timeout(Duration.create(5, SECONDS))); Integer result = agent.await(new Timeout(5, SECONDS));
//#read-await //#read-await
assertEquals(result, new Integer(14)); assertEquals(result, new Integer(14));

10
akka-docs/java/code/akka/docs/transactor/TransactorDocTest.java
View file

@ -13,7 +13,7 @@ import akka.dispatch.Await;
import akka.transactor.Coordinated; import akka.transactor.Coordinated;
import akka.util.Duration; import akka.util.Duration;
import akka.util.Timeout; import akka.util.Timeout;
import java.util.concurrent.TimeUnit; import static java.util.concurrent.TimeUnit.SECONDS;
//#imports //#imports
public class TransactorDocTest { public class TransactorDocTest {
@ -26,7 +26,7 @@ public class TransactorDocTest {
ActorRef counter1 = system.actorOf(new Props().withCreator(CoordinatedCounter.class)); ActorRef counter1 = system.actorOf(new Props().withCreator(CoordinatedCounter.class));
ActorRef counter2 = system.actorOf(new Props().withCreator(CoordinatedCounter.class)); ActorRef counter2 = system.actorOf(new Props().withCreator(CoordinatedCounter.class));
Timeout timeout = new Timeout(Duration.create(5, TimeUnit.SECONDS)); Timeout timeout = new Timeout(5, SECONDS);
counter1.tell(new Coordinated(new Increment(counter2), timeout)); counter1.tell(new Coordinated(new Increment(counter2), timeout));
@ -41,7 +41,7 @@ public class TransactorDocTest {
@Test @Test
public void coordinatedApi() { public void coordinatedApi() {
//#create-coordinated //#create-coordinated
Timeout timeout = new Timeout(Duration.create(5, TimeUnit.SECONDS)); Timeout timeout = new Timeout(5, SECONDS);
Coordinated coordinated = new Coordinated(timeout); Coordinated coordinated = new Coordinated(timeout);
//#create-coordinated //#create-coordinated
@ -66,7 +66,7 @@ public class TransactorDocTest {
ActorSystem system = ActorSystem.create("CounterTransactor"); ActorSystem system = ActorSystem.create("CounterTransactor");
ActorRef counter = system.actorOf(new Props().withCreator(Counter.class)); ActorRef counter = system.actorOf(new Props().withCreator(Counter.class));
Timeout timeout = new Timeout(Duration.create(5, TimeUnit.SECONDS)); Timeout timeout = new Timeout(5, SECONDS);
Coordinated coordinated = new Coordinated(timeout); Coordinated coordinated = new Coordinated(timeout);
counter.tell(coordinated.coordinate(new Increment())); counter.tell(coordinated.coordinate(new Increment()));
coordinated.await(); coordinated.await();
@ -83,7 +83,7 @@ public class TransactorDocTest {
ActorRef friend = system.actorOf(new Props().withCreator(Counter.class)); ActorRef friend = system.actorOf(new Props().withCreator(Counter.class));
ActorRef friendlyCounter = system.actorOf(new Props().withCreator(FriendlyCounter.class)); ActorRef friendlyCounter = system.actorOf(new Props().withCreator(FriendlyCounter.class));
Timeout timeout = new Timeout(Duration.create(5, TimeUnit.SECONDS)); Timeout timeout = new Timeout(5, SECONDS);
Coordinated coordinated = new Coordinated(timeout); Coordinated coordinated = new Coordinated(timeout);
friendlyCounter.tell(coordinated.coordinate(new Increment(friend))); friendlyCounter.tell(coordinated.coordinate(new Increment(friend)));
coordinated.await(); coordinated.await();

3
akka-transactor/src/test/java/akka/transactor/UntypedCoordinatedIncrementTest.java
View file

@ -22,7 +22,6 @@ import akka.testkit.AkkaSpec;
import akka.testkit.EventFilter; import akka.testkit.EventFilter;
import akka.testkit.ErrorFilter; import akka.testkit.ErrorFilter;
import akka.testkit.TestEvent; import akka.testkit.TestEvent;
import akka.util.Duration;
import akka.util.Timeout; import akka.util.Timeout;
import java.util.Arrays; import java.util.Arrays;
@ -54,7 +53,7 @@ public class UntypedCoordinatedIncrementTest {
int numCounters = 3; int numCounters = 3;
int timeoutSeconds = 5; int timeoutSeconds = 5;
Timeout timeout = new Timeout(Duration.create(timeoutSeconds, TimeUnit.SECONDS)); Timeout timeout = new Timeout(timeoutSeconds, TimeUnit.SECONDS);
@Before @Before
public void initialise() { public void initialise() {

3
akka-transactor/src/test/java/akka/transactor/UntypedTransactorTest.java
View file

@ -22,7 +22,6 @@ import akka.testkit.AkkaSpec;
import akka.testkit.EventFilter; import akka.testkit.EventFilter;
import akka.testkit.ErrorFilter; import akka.testkit.ErrorFilter;
import akka.testkit.TestEvent; import akka.testkit.TestEvent;
import akka.util.Duration;
import akka.util.Timeout; import akka.util.Timeout;
import java.util.Arrays; import java.util.Arrays;
@ -55,7 +54,7 @@ public class UntypedTransactorTest {
int numCounters = 3; int numCounters = 3;
int timeoutSeconds = 5; int timeoutSeconds = 5;
Timeout timeout = new Timeout(Duration.create(timeoutSeconds, TimeUnit.SECONDS)); Timeout timeout = new Timeout(timeoutSeconds, TimeUnit.SECONDS);
@Before @Before
public void initialise() { public void initialise() {