Scala NSQ client built on top of Finagle

Example Usage

val nsq = NsqSubscriber("Mindtalk", "MindtalkApp",
    "127.0.0.1:4161", "mindtalk", "nsqie")

nsq.listen { case (topic, channel, msg) =>
    println("got data %s from topic %s in channel %s".format(msg, topic, channel))
    MessageHandleReturn.SUCCESS
}

NsqClient.publish("127.0.0.1:4151", "mindtalk",
    "hello " + System.currentTimeMillis() + " :P")

Under heavy development, don't use this in production.

[] Robin Sy.