Simple "overwatch" actor to shut down the system when done.

Scraper.scala

import akka.actor._

object Scraper {
  def props = Props[Scraper]
}

class Scraper extends Actor with ActorLogging with Unhandled {

  import MigrationProtocol._

  val sources = context.actorOf(Props[Sources])

  def receive = {

    case parse @ Parse(_) =>
      context.actorOf(Job.props(sources)) ! parse

    case Done =>
      context.self ! PoisonPill
      context.system.shutdown()
  }
}