Package akka.actor

Examples of akka.actor.ActorRef.tell()

49
50
51
52
53
54
55
56
57
58
59
        // Create the "actor-in-a-box"
        final Inbox inbox = Inbox.create(system);

        // Tell the 'greeter' to change its 'greeting' message
        greeter.tell(new WhoToGreet("akka"), ActorRef.noSender());

        // Ask the 'greeter for the latest 'greeting'
        // Reply should go to the "actor-in-a-box"
        inbox.send(greeter, new Greet());
View Full Code Here
60
61
62
63
64
65
66
67
68
69
70
        // Wait 5 seconds for the reply with the 'greeting' message
        Greeting greeting1 = (Greeting) inbox.receive(Duration.create(5, TimeUnit.SECONDS));
        System.out.println("Greeting: " + greeting1.message);

        // Change the greeting and ask for it again
        greeter.tell(new WhoToGreet("typesafe"), ActorRef.noSender());
        inbox.send(greeter, new Greet());
        Greeting greeting2 = (Greeting) inbox.receive(Duration.create(5, TimeUnit.SECONDS));
        System.out.println("Greeting: " + greeting2.message);

        // after zero seconds, send a Greet message every second to the greeter with a sender of the GreetPrinter
View Full Code Here
170
171
172
173
174
175
176
177
178
            listener);
      }
    }), "master");

    // start the calculation
    master.tell(new Calculate());

  }
}
View Full Code Here
27
28
29
30
31
32
33
34
35
36
37
  public static void main(String... args) {
        ActorSystem system = ActorSystem.create("example");

        ActorRef counter = system.actorOf(new Props(Counter.class));

        counter.tell("tick");
        counter.tell("tick");
        counter.tell("tick");

        Future future = ask(counter, "get", 5000);
View Full Code Here
28
29
30
31
32
33
34
35
36
37
38
        ActorSystem system = ActorSystem.create("example");

        ActorRef counter = system.actorOf(new Props(Counter.class));

        counter.tell("tick");
        counter.tell("tick");
        counter.tell("tick");

        Future future = ask(counter, "get", 5000);

        future.onSuccess(new OnSuccess<Integer>() {
View Full Code Here
29
30
31
32
33
34
35
36
37
38
39
        ActorRef counter = system.actorOf(new Props(Counter.class));

        counter.tell("tick");
        counter.tell("tick");
        counter.tell("tick");

        Future future = ask(counter, "get", 5000);

        future.onSuccess(new OnSuccess<Integer>() {
            public void onSuccess(Integer count) {
View Full Code Here
31
32
33
34
35
36
37
38
39
40
41
    }

    @Test
    public void testCreateOperation() throws Exception {
        ActorRef ref = createActorRef();
        ref.tell(getClass());

        Thread.sleep(1000);

        Operation operation = getLastEntered();
        Operation expected = new Operation().type(AkkaDefinitions.OperationTypes.AKKA_OP_UNTYPED_ACTOR)
View Full Code Here
181
182
183
184
185
186
187
188
189
190
191
        @Override
        public void run() {
          try {
            slaveProgressMessage progressMessage = (slaveProgressMessage) Await
                .result(progress, duration);
            m.tell(new notCongestionSignal(), ActorRef.noSender());
            if (progressMessage.completed) {
              if (!collectedManager.containsKey(m)) {
                completedButNotCollectedManager.add(m);
                collectedManager.put(m, true);
              }
View Full Code Here
177
178
179
180
181
182
183
184
185
186
187
                  fqdn
                ));

        workers.add(worker);

        worker.tell(AggregationWorker.MessageType.PROCESS_REQUEST,
            getSelf());

      }// end for loop
     
      //TODO
View Full Code Here
301
302
303
304
305
306
307
308
309
310
311
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
     
      // origin manager
      worker.tell(
          OperationWorker.MessageType.PROCESS_REQUEST,
          originalManager);

      processedWorkerCount++;
      trueProcessedWorkerCount++;
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.