@Test public void testInform() throws Exception { new JavaTestKit(system) { { final Props props = LobbyBalancerActor.props(configuration, 0, 5); final ActorRef subject = system.actorOf(props); final RequestInformation req = RequestInformation.INSTANCE; watch(subject); subject.tell(req, getRef()); expectMsgEquals(duration("1 second"), new LobbyBalancer(Collections.emptyMap())); } }; }
private void inform() { sender().tell(new LobbyBalancer(Collections.unmodifiableMap(instances)), self()); }
LobbyBalancerActor extends AbstractActor { private void inform() { sender().tell(new LobbyBalancer(Collections.unmodifiableMap(instances)), self()); } }
LobbyBalancerActor extends AbstractActor { private void inform() { sender().tell(new LobbyBalancer(Collections.unmodifiableMap(instances)), self()); } private  LobbyBalancerActor(LobbyConfiguration configuration, int min, int max); }
LobbyBalancerActor extends AbstractActor { private void inform() { sender().tell(new LobbyBalancer(Collections.unmodifiableMap(instances)), self()); } private  LobbyBalancerActor(LobbyConfiguration configuration, int min, int max); @Override void preStart(); @Override PartialFunction<Object, BoxedUnit> receive(); static Props props(LobbyConfiguration configuration, int min, int max); static Props props(LobbyConfiguration configuration); }
LobbyBalancerActor extends AbstractActor { private void inform() { sender().tell(new LobbyBalancer(Collections.unmodifiableMap(instances)), self()); } private  LobbyBalancerActor(LobbyConfiguration configuration, int min, int max); @Override void preStart(); @Override PartialFunction<Object, BoxedUnit> receive(); static Props props(LobbyConfiguration configuration, int min, int max); static Props props(LobbyConfiguration configuration);  }