Play 2.2.x WSClientVisitor

gistfile1.scala

// define our events
case class RegisterSocket()
case class Connected(out: Enumerator[JsValue], ref: ActorRef)
 
class WSClientVisitor(name: String) extends Actor with ActorLogging with WebSocketChannel
{
   def receive = {
      case RegisterSocket => {
          // close over sender
          val myClient = sender
          // establish connection
          myClient ! Connected(out,self)
          // send a test message
          push(Json.obj("type" -> "event", “data” -> “connection_on”))
        }
   }
}