ws-try-accept-with-actor.scala

class Application extends Controller {
  
  ... 
  
  implicit val akkaSystem = akka.actor.ActorSystem()
  
  val redis = RedisClient()
  
  def index = Action { implicit request =>
    Ok(views.html.pubsub())
  }
  
  def subscribe = WebSocket.tryAcceptWithActor[String, String] { request =>
    def props(channel: String)(out: ActorRef) = Props(classOf[SubscribeActor], redis, 
      out, Seq(channel), Nil).withDispatcher("rediscala-worker-dispatcher")
    Future.successful(request.getQueryString("channel") match {
      case None => Left(Forbidden)
      case Some(channel) => Right(props(channel))
    })
  }
  
  def publish(channel: String) = Action.async { implicit request =>
    request.body.asFormUrlEncoded.flatMap{ params =>
      params.get("message").map{ message =>
        redis.publish(channel, message.head).map{ n =>
          if(n > 0) {
            log.debug(s"Number of subscriber: $n s")
            Ok(n.toString)
          }else {
            log.debug("No recipient")
            Gone
          }
        }
      }
    }.getOrElse(Future.successful(BadRequest("No content received")))
  }
  ...
}