SubscribeActor.scala

class SubscribeActor(redis: RedisClient, out: ActorRef, 
    channels: Seq[String] = Nil, patterns: Seq[String] = Nil) extends RedisSubscriberActor(
    new InetSocketAddress(redis.host, redis.port), channels, patterns,
    onConnectStatus = connected => { println(s"connected: $connected") }) {

  def onMessage(message: Message) {
    out ! message.data.decodeString("UTF-8")
  }

  def onPMessage(pmessage: PMessage) {}
  ...
}