Play 2.2.x Controller

gistfile1.scala

object Application extends Controller {
 
  /* Each WebSocket connection state is managed by an Agent actor.
  A new actor is created for each WebSocket, and is killed when the socket is closed.
  For each play actor agent, a unique WebSocket Client Worker actor is created to process WS events via the WSManager Actor.
  */
  def websocketManager(deviceId: String) = WebSocket.async[JsValue]
  {
    request =>
    // instantiate an actor to hold web socket
    val webSocketWorker = Akka.system.actorOf(Props(new WSClientVisitor(deviceId),name=deviceId)
    
    //specify a timeout for the registration request
    implicit val timeout = Timeout(Duration(2,"seconds"))
    //register device
    (webSocketWorker ? RegisterSocket).map {
      //establish connection with wsClient Worker, which will process messages to our socket
        case Connected(out, myWorker) => {
          // acknowledge connection
            val in = Iteratee.foreach[JsValue] {
              event => myWorker ! Message(event)
              }.mapDone(_ => myWorker ! Logger.info(s" Received Websocket FIN command from device: $deviceId"))
              (in,out)
        }
        case NotConnected(out) => {
          (Iteratee.ignore[JsValue],out)
          }
    }
  }
}