BlogRedisPubActor.scala

import akka.actor.{Actor, ActorRef, Props}
import com.redis.{Publish, Publisher}
import Models.RedisPublishMessage

object RedisPubActor {
  def props(redis: Redis): Props = {
    val publisherProps = Props(new Publisher(redis.client))
    Props(new RedisPubActor(publisherProps))
  }
}

class RedisPubActor(publisherProps: Props) extends Actor {
  private val publisher: ActorRef = context.actorOf(publisherProps)

  def receive: Receive = {
    case RedisPublishMessage(ch, msg) => publish(ch, msg)
  }

  private def publish(channel: String, message: String) = {
    publisher ! Publish(channel, message)
  }
}