Skip to content

Instantly share code, notes, and snippets.

@samuelorji
Last active May 29, 2019 15:11
Show Gist options
  • Select an option

  • Save samuelorji/97b51f430870af23c2db8ddf430e1d8d to your computer and use it in GitHub Desktop.

Select an option

Save samuelorji/97b51f430870af23c2db8ddf430e1d8d to your computer and use it in GitHub Desktop.
object QueueManager {
case object Start
def createSchedulers(schedulers : List[Props]) : Props = Props(new QueueManager(schedulers))
}
private [Manager] class QueueManager(schedulers : List[Props]) extends Actor with ActorLogging {
import QueueManager._
override def preStart(): Unit =
schedulers.foreach(context.actorOf(_))
self ! Start
override def receive: Receive = {
case Start =>
context.children.foreach( _ ! Poll)
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment