Package akka.actor

Examples of akka.actor.ActorRef.tell()

208
209
210
211
212
213
214
215
216
217
218
     
      // FIXME: this is a bugfix, because messages are not properly sent without
      // prior calling of the actorSystem
      String ars = actorRef.path().toString();
      ActorRef ar = actorSystem.actorFor(ars);
      ar.tell(message, this.getSelf());
     
//      actorRef.tell(message, this.getSelf());
    }
  }
 
View Full Code Here
161
162
163
164
165
166
167
168
    ActorRef actorRef = new ActorReferenceService().getActorReference(uniqueFlowNodeId);
   
    LOG.debug("Sending TriggerMessage to " + actorRef);
   
    actorRef.tell(triggerMessage, null);
  } 
}
View Full Code Here
127
128
129
130
131
132
133
134
135
136
137
      ActorRef cache = system.actorOf(
          new ConsistentHashingPool(10).withHashMapper(hashMapper).props(
              Props.create(Cache.class)),
        "cache");

      cache.tell(new ConsistentHashableEnvelope(
        new Entry("hello", "HELLO"), "hello"), getRef());
      cache.tell(new ConsistentHashableEnvelope(
        new Entry("hi", "HI"), "hi"), getRef());

      cache.tell(new Get("hello"), getRef());
View Full Code Here
129
130
131
132
133
134
135
136
137
138
139
              Props.create(Cache.class)),
        "cache");

      cache.tell(new ConsistentHashableEnvelope(
        new Entry("hello", "HELLO"), "hello"), getRef());
      cache.tell(new ConsistentHashableEnvelope(
        new Entry("hi", "HI"), "hi"), getRef());

      cache.tell(new Get("hello"), getRef());
      expectMsgEquals("HELLO");
View Full Code Here
132
133
134
135
136
137
138
139
140
141
142
      cache.tell(new ConsistentHashableEnvelope(
        new Entry("hello", "HELLO"), "hello"), getRef());
      cache.tell(new ConsistentHashableEnvelope(
        new Entry("hi", "HI"), "hi"), getRef());

      cache.tell(new Get("hello"), getRef());
      expectMsgEquals("HELLO");

      cache.tell(new Get("hi"), getRef());
      expectMsgEquals("HI");
View Full Code Here
135
136
137
138
139
140
141
142
143
144
145
        new Entry("hi", "HI"), "hi"), getRef());

      cache.tell(new Get("hello"), getRef());
      expectMsgEquals("HELLO");

      cache.tell(new Get("hi"), getRef());
      expectMsgEquals("HI");

      cache.tell(new Evict("hi"), getRef());
      cache.tell(new Get("hi"), getRef());
      expectMsgEquals(NOT_FOUND);
View Full Code Here
38
39
40
41
42
43
44
45
46
47
48
  @Override
  public void preStart() throws Exception {
    //#manager
    final ActorRef tcpManager = Tcp.get(getContext().system()).manager();
    //#manager
    tcpManager.tell(
        TcpMessage.bind(getSelf(), new InetSocketAddress("localhost", 0), 100),
        getSelf());
  }

  @Override
View Full Code Here
138
139
140
141
142
143
144
145
146
147
148
      expectMsgEquals("HELLO");

      cache.tell(new Get("hi"), getRef());
      expectMsgEquals("HI");

      cache.tell(new Evict("hi"), getRef());
      cache.tell(new Get("hi"), getRef());
      expectMsgEquals(NOT_FOUND);

      //#consistent-hashing-router
    }};
View Full Code Here
139
140
141
142
143
144
145
146
147
148
149
      cache.tell(new Get("hi"), getRef());
      expectMsgEquals("HI");

      cache.tell(new Evict("hi"), getRef());
      cache.tell(new Get("hi"), getRef());
      expectMsgEquals(NOT_FOUND);

      //#consistent-hashing-router
    }};
  }
View Full Code Here
371
372
373
374
375
376
377
378
379
380
381
  public void demonstrateBroadcast() {
    new JavaTestKit(system) {{
      ActorRef router = system.actorOf(new RoundRobinPool(5).props(
        Props.create(Echo.class)));
      //#broadcastDavyJonesWarning
      router.tell(new Broadcast("Watch out for Davy Jones' locker"), getTestActor());
      //#broadcastDavyJonesWarning
      assertEquals(5, receiveN(5).length);
    }};
  }
 
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.