package controllers

import play.api._
import play.api.mvc._
import scala.concurrent.duration._
import akka.actor.{Actor, Props}
import play.api.libs.concurrent.Akka
import play.api.libs.concurrent.Execution.Implicits._
import controllers._
import akka.pattern.ask
import akka.util.Timeout
import scala.concurrent._
import play.api.libs.iteratee._

import play.api.libs.concurrent._


object Application extends Controller {
  import play.api.Play.current
	implicit val timeout = Timeout(1 seconds)
	lazy val actorA = Akka.system.actorOf(Props(new TestActorGenerator("A")),name="actorA")
	lazy val actorB = Akka.system.actorOf(Props(new TestActorGenerator("B")),name="actorB")
	lazy val started = {
	val consumeA = Akka.system.actorOf(Props(new TestActorConsumer("A",actorA)),name="consumeA")
	val consumeB = Akka.system.actorOf(Props(new TestActorConsumer("B",actorB)),name="consumeB")
	val patchPanel = Akka.system.actorOf(Props(new TestActorPanelConsumer("C",actorA,actorB)),name="patchPanel")
	val consumeC = Akka.system.actorOf(Props(new TestActorConsumer("C",patchPanel)),name="consumeC")
	Akka.system.scheduler.schedule(0 seconds, 1 seconds, actorA, SendMsg())
	Akka.system.scheduler.schedule(0 seconds, 1 seconds, actorB, SendMsg())
	Akka.system.scheduler.schedule(0 seconds, 20 seconds, patchPanel, Add(actorA))
	Akka.system.scheduler.schedule(10 seconds, 20 seconds, patchPanel, Add(actorB))
	patchPanel ! Add(actorA)
	patchPanel ! Add(actorB)
		true
	}
//  val consume = Iteratee.consume[String]{case s => println(s)}
  def index = Action {
 
		import play.api.Play.current
		started
	    Ok(views.html.index("Your new application is ready."))
  }
 
}