Learning Akka, simple example

app.scala

package info.schleichardt.learning.akka

import akka.actor._
import akka.routing.RoundRobinRouter

object SimpleApp extends App {

  val system = ActorSystem("MySystem")
  val listener = system.actorOf(Props[Listener], name = "listener")
  val master = system.actorOf(Props(new Master(listener)), name = "master")
  master ! Start
}

class Worker extends Actor {
  def receive = {
    case _ => sender ! Answer
  }
}

class Master(listener: ActorRef) extends Actor {

  val workerRouter = {
    val nrOfInstances = 4
    context.actorOf(
      Props[Worker].withRouter(RoundRobinRouter(nrOfInstances)), name = "workerRouter")
  }

  def receive = {
    case Start =>
      workerRouter ! Start

    case Answer =>
      listener ! Finished
      context.stop(self)
      context.system.shutdown()
      println("master bye bye")
  }
}

class Listener extends Actor {
  def receive = {
    case _ =>
      println("listener")

  }
}

object Start

object Answer

object Finished