RoutingTest

    @Override
    public Receive createReceive() {
        return receiveBuilder()
                .match(
                        WorkMessage.class,
                        message -> {
                            String pathName = self().path().name();
                            messageCount++;
                            log.info("[{}] ChildActor InMessage : {} - {}", pathName, message, messageCount);
                            // Routee가 a일때 임의 지연
                            if(pathName.equals("$a")){
                                log.info("SomeBlocking - 300ms");
                                Thread.sleep(300);
                            }
                            _probe.tell("completed", ActorRef.noSender());
                        })
                .build();
    }

akka.actor.deployment {
  /router1 {
    router = round-robin-pool
    nr-of-instances = 5
  }

  /router2 {
    router = random-pool
    nr-of-instances = 5
  }

  /router3 {
    router = balancing-pool
    nr-of-instances = 5
    pool-dispatcher {
      attempt-teamwork = off
    }
  }

  /router4 {
    router = balancing-pool
    nr-of-instances = 5
    pool-dispatcher {
      executor = "thread-pool-executor"

      # Thread Pool을 지정할수도 있습니다.
      thread-pool-executor {
        core-pool-size-min = 5
        core-pool-size-max = 5
      }
    }
  }

  /router5 {
    router = smallest-mailbox-pool
    nr-of-instances = 5
  }}

ActorRef router = actorSystem.actorOf(FromConfig.getInstance()
.props(WorkerActor.Props(probe.getRef())), routerName);


@Test
public void RoundRobinRoutingTest(){
RouterByNameTest("router1");
}

@Test
public void RandomRoutingTest(){
RouterByNameTest("router2");
}

@Test
public void BalancingRoutingTest(){
RouterByNameTest("router3");
}