Sub.scala

object Sub {
  println("starting subscription service ..")
  val s = new Subscriber(new RedisClient("localhost", 6379))
  s.start
  s ! Register(callback) 

  def sub(channels: String*) = {
    s ! Subscribe(channels.toArray)
  }

  def unsub(channels: String*) = {
    s ! Unsubscribe(channels.toArray)
  }

  def callback(pubsub: PubSubMessage) = pubsub match {
    //..
  }
}