Akka Pool Router

AkkaPoolRouter.scala

import akka.actor.{Actor, ActorLogging, ActorSystem, Props}
import akka.event.Logging
import akka.routing.RoundRobinPool

import scala.concurrent.Await
import scala.concurrent.duration._

object RouteeActor {
  def props(): Props = Props[RouteeActor]
}

class RouteeActor extends Actor with ActorLogging {

  log.info("Starting route actor: {}", self)

  def receive = {
    case msg => log.info("Message received: {}", msg)
  }
}

object Main extends App {

  implicit val system = ActorSystem("api-akka-http-system")
  val log = Logging(system, getClass)

  // Initialize router
  val router = system.actorOf(RoundRobinPool(5).props(RouteeActor.props()), "router")

  scala.sys.addShutdownHook{
    log.info("Shutting down server and actor system")
    system.terminate()
    Await.result(system.whenTerminated, 30 seconds)
  }
}