jobs.js

var Nsq = require('nsqjs');
var writer = new Nsq.Writer('127.0.0.1', 4150);

var queue = [];

writer.connect();

/* istanbul ignore next */
writer.on('ready', function() {

    /* istanbul ignore next */
    queue.forEach(function(msg) {

        exports.create(msg.topic, msg.message, msg.done);
    });
});

/* istanbul ignore next */
exports.create = function(topic, message, done) {


    if (writer.conn) {

        writer.publish(topic, message, done);
    } else {
        queue.push({
            topic: topic,
            message: message,
            done: done
        });
    }
};