Akka/Scala example source code file (ArithmeticServiceTest.java)

This example Akka source code file (ArithmeticServiceTest.java) is included in my "Source Code Warehouse" project. The intent of this project is to help you more easily find Akka and Scala source code examples by using tags.

All credit for the original source code belongs to akka.io; I'm just trying to make examples easier to find. (For my Scala work, see my Scala examples and tutorials.)

Akka tags/keywords

actor, actorref, actorsystem, add, afterclass, akka, beforeclass, const, divide, javatestkit, test, testing, testkit, thearithmeticserviceshouldcalculateconstantexpressionsproperly

The ArithmeticServiceTest.java Akka example source code

package supervision;

import akka.actor.ActorRef;
import akka.actor.ActorSystem;
import akka.actor.Props;
import akka.actor.Status;
import akka.testkit.JavaTestKit;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;

import java.util.stream.IntStream;
import static supervision.Expression.*;

public class ArithmeticServiceTest {
  static ActorSystem system;

  @BeforeClass
  public static void setup() {
    system = ActorSystem.create("BuncherTest");
  }

  @AfterClass
  public static void tearDown() {
    JavaTestKit.shutdownActorSystem(system);
    system = null;
  }

  @Test
  public void TheArithmeticServiceShouldCalculateConstantExpressionsProperly(){
    new JavaTestKit(system) {{
      final ActorRef service =
        system.actorOf(Props.create(ArithmeticService.class));
      final ActorRef probe = getRef();
      IntStream.range(-2, 3).forEach(x -> {
        service.tell(new Const(x), probe);
        expectMsgEquals(x);
      });
    }};
  }

  @Test
  public void TheArithmeticServiceShouldCalculateAdditionProperly(){
    new JavaTestKit(system) {{
      final ActorRef service =
        system.actorOf(Props.create(ArithmeticService.class));
      final ActorRef probe = getRef();
      IntStream.range(-2, 3).forEach(x ->
        IntStream.range(-2, 3).forEach(y -> {
          service.tell(new Add(new Const(x), new Const(y)), probe);
          expectMsgEquals(x + y);
        })
      );
    }};
  }

  @Test
  public void TheArithmeticServiceShouldCalculateMultiplicationAndDivisionProperly(){
    new JavaTestKit(system) {{
      final ActorRef service =
        system.actorOf(Props.create(ArithmeticService.class));
      final ActorRef probe = getRef();
      IntStream.range(-2, 3).forEach(x ->
        IntStream.range(-2, 3).forEach(y -> {
          service.tell(new Multiply(new Const(x), new Const(y)), probe);
          expectMsgEquals(x * y);
        })
      );

      // Skip zero in the second parameter
      IntStream.range(-2, 3).forEach(x ->
        IntStream.of(-2, -1, 1, 2).forEach(y -> {
          service.tell(new Divide(new Const(x), new Const(y)), probe);
          expectMsgEquals(x / y);
        })
      );
    }};
  }

  @Test
  public void TheArithmeticServiceShouldSurviveIllegalExpressions(){
    new JavaTestKit(system) {{
      final ActorRef service =
        system.actorOf(Props.create(ArithmeticService.class));
      final ActorRef probe = getRef();

      service.tell(new Divide(new Const(1), new Const(0)), probe);
      expectMsgClass(Status.Failure.class);

      service.tell(new Add(null, new Const(0)), probe);
      expectMsgClass(Status.Failure.class);

      service.tell(new Add(new Const(1), new Const(0)), probe);
      expectMsgEquals(1);
    }};
  }
}