import akka.actor.{ActorSystem, Props}
import akka.dispatch.ExecutionContexts._
import akka.pattern.ask
import akka.util.Timeout
import domain.Start

import scala.concurrent.duration._

object WordCounter extends App {
  implicit  val gc = global
  implicit val timeout = Timeout(25 seconds)
  val system = ActorSystem("MyWordCounter")

  val master = system.actorOf(Props(Master("/home/sri/rdp.sh")))
  val future = master ? Start
  future.map { res =>
    println(res)
    system.terminate()
  }
}