Pub.scala

object Pub {
  println("starting publishing service ..")
  val p = new Publisher(new RedisClient("localhost", 6379))
  p.start

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