worker.js

#!/usr/bin/env node

var Hoek = require('hoek');
var nsq = require('nsqjs');
var email = require('../lib/email');

var internals = {
    topicName: 'send-email',
    channel: 'worker',
    lookupd: ['localhost:4150']
};

internals.defaults = {

};

var reader = new nsq.Reader(internals.topicName, internals.channel, {
    nsqdTCPAddresses: internals.lookupd
});

reader.on('message', function(msg) {

    var job = JSON.parse(msg.body);

    var template = job.template;

    delete job.template;

    email(template, job, function(err) {

        if (err) {

            console.log(err);
        }
        msg.finish();
    });
});

reader.connect(function (err) {
    console.log(arguments);
});