Package akka.util

Examples of akka.util.Duration

121
122
123
124
125
126
127
128
129
130
131
        Result result = (Result) message;
        pi += result.getValue();
        nrOfResults += 1;
        if (nrOfResults == nrOfMessages) {
          // Send the result to the listener
          Duration duration = Duration.create(
              System.currentTimeMillis() - start,
              TimeUnit.MILLISECONDS);
          listener.tell(new PiApproximation(pi, duration), getSelf());
          // Stops this actor and all its supervised children
          getContext().stop(getSelf());
View Full Code Here
138
139
140
141
142
143
144
145
146
147
148
  public void testSupervisorStrategy1() throws Exception {

    ActorRef supervisorActorRef1 = _system.actorOf(new Props(
        SupervisorActor.class), "supervisor1");

    Duration timeout = Duration.parse("5 second");
    // register the BoomActor with the Supervisor
    final ActorRef child = (ActorRef) Await.result(
        ask(supervisorActorRef1, new Props(BoomActor.class), 5000),
        timeout);
View Full Code Here
21
22
23
24
25
26
27
28
        this.name = name;
    }

    @Override public TransactionFactory transactionFactory() {
        return new TransactionFactoryBuilder()
            .setTimeout(new Duration(3, TimeUnit.SECONDS))
            .build();
    }
View Full Code Here
TOP

Related Classes of akka.util.Duration

  • akka.transactor.test.UntypedCounter
  • akka.tutorial.first.java.Pi$Master
  • org.akka.essentials.unittest.example.ExampleUnitTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.