NSQ class-based consumer

consumer.py

import nsq


class NSQWorker:

    def __init__(self, *args, **kwargs):
        self.banner = 'Hello from worker'

    def process_message(self, message):
        print(self.banner)
        print(message.id)
        print(message.body)
        return True


worker = NSQWorker()
p1 = nsq.Reader(
    message_handler=lambda m: worker.process_message(m),
    lookupd_http_addresses=['http://127.0.0.1:4161'],
    topic='dev_p1',
    channel='worker',
)
p2 = nsq.Reader(
    message_handler=lambda m: worker.process_message(m),
    lookupd_http_addresses=['http://127.0.0.1:4161'],
    topic='dev_p2',
    channel='worker',
)
nsq.run()