Examples of akka.testkit.JavaTestKit

akka.testkit.JavaTestKit
Java API: Test kit for testing actors. Inheriting from this class enables reception of replies from actors, which are queued by an internal actor and can be examined using the expectMsg... methods. Assertions and bounds concerning timing are available in the form of Within blocks.
Beware of two points:
- the ActorSystem passed into the constructor needs to be shutdown, otherwise thread pools and memory will be leaked - this trait is not thread-safe (only one actor with one queue, one stack of Within blocks); take care not to run tests within a single test class instance in parallel.
- It should be noted that for CI servers and the like all maximum Durations are scaled using the dilated method, which uses the TestKitExtension.Settings.TestTimeFactor settable via akka.conf entry "akka.test.timefactor".

        system.awaitTermination(Duration.create("10 seconds"));
    }


    @Test
    public void testSetGreeter() {
        new JavaTestKit(system) {{
            final TestActorRef<HelloAkkaJava.Greeter> greeter =
                    TestActorRef.create(system, Props.create(HelloAkkaJava.Greeter.class), "greeter1");


            greeter.tell(new HelloAkkaJava.WhoToGreet("testkit"), getTestActor());

View Full Code Here

        }};
    }


    @Test
    public void testGetGreeter() {
        new JavaTestKit(system) {{


            final ActorRef greeter = system.actorOf(Props.create(HelloAkkaJava.Greeter.class), "greeter2");


            greeter.tell(new HelloAkkaJava.WhoToGreet("testkit"), getTestActor());
            greeter.tell(new HelloAkkaJava.Greet(), getTestActor());

View Full Code Here


    @Before
    public void setUp() throws Exception
    {
        system = ActorSystem.create("test-system");
        messageProbe = new JavaTestKit(system);
        watchingProbe = new JavaTestKit(system);


        before();
    }

View Full Code Here

    @PostConstruct
    public void initialize()
    {
        factory = new CdiAwareCreatorFactory(beanManager);
        system = ActorSystem.create("System");
        probe = new JavaTestKit(system);
    }

View Full Code Here

    //#dispatchers
  }
  
  @Test
  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

View Full Code Here

    }};
  }
  
  @Test
  public void demonstratePoisonPill() {
    new JavaTestKit(system) {{
      ActorRef router = watch(system.actorOf(new RoundRobinPool(5).props(
        Props.create(Echo.class))));
      //#poisonPill
      router.tell(PoisonPill.getInstance(), getTestActor());
      //#poisonPill

View Full Code Here

    }};
  }
  
  @Test
  public void demonstrateBroadcastPoisonPill() {
    new JavaTestKit(system) {{
      ActorRef router = watch(system.actorOf(new RoundRobinPool(5).props(
        Props.create(Echo.class))));
      //#broadcastPoisonPill
      router.tell(new Broadcast(PoisonPill.getInstance()), getTestActor());
      //#broadcastPoisonPill

View Full Code Here

    }};
  }
  
  @Test
  public void demonstrateKill() {
    new JavaTestKit(system) {{
      ActorRef router = watch(system.actorOf(new RoundRobinPool(5).props(
        Props.create(Echo.class))));
      //#kill
      router.tell(Kill.getInstance(), getTestActor());
      //#kill

View Full Code Here

    }};
  }
  
  @Test
  public void demonstrateBroadcastKill() {
    new JavaTestKit(system) {{
      ActorRef router = watch(system.actorOf(new RoundRobinPool(5).props(
        Props.create(Echo.class))));
      //#broadcastKill
      router.tell(new Broadcast(Kill.getInstance()), getTestActor());
      //#broadcastKill

View Full Code Here


  private final ActorSystem system = actorSystemResource.getSystem();


  @Test
  public void testConnection() {
    new JavaTestKit(system) {
      {
        @SuppressWarnings("unused")
        final ActorRef server = system.actorOf(Props.create(Server.class, getRef()), "server1");
        final InetSocketAddress listen = expectMsgClass(Bound.class).localAddress();
        final ActorRef client = system.actorOf(Props.create(Client.class, listen, getRef()), "client1");

View Full Code Here

0 1 2 3 4

TOP

Related Classes of akka.testkit.JavaTestKit

akka.camel.ConsumerJavaTest

com.chen.akka.HelloAkkaTest

com.fourtyfourblocks.akka.testing.cdi.CdiTestingWorld

com.fourtyfourblocks.akka.testing.GuiceTestKitBase

docs.actor.ActorDocTest

docs.actor.fsm.BuncherTest

docs.actor.fsm.FSMDocTest

docs.actor.InboxDocTest

docs.actor.InitializationDocSpecJava

docs.actor.InitializationDocTest

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.