Example NSQ Reader

reader.py

"""
Usage:

./reader.py --nsqd-tcp-address=address:port --topic=topic --channel=channel
"""

import nsq
import tornado.options

def handler(message):
    print message.body, message.attempts
    message.finish()

def run():
    r = nsq.Reader(message_handler=handler,
            nsqd_tcp_addresses=[tornado.options.options.nsqd_tcp_address],
            topic=tornado.options.options.topic, 
            channel=tornado.options.options.channel, 
        )
    nsq.run()

if __name__ == "__main__":
    tornado.options.define("nsqd_tcp_address", type=str, help="the destination NSQd address:port")
    tornado.options.define("topic", type=str, help="the NSQ Topic to consume from")
    tornado.options.define("channel", type=str, help="the NSQ Channel to consume from")
    tornado.options.parse_command_line()
    run()