patch-domain-kue.js

var worker = require('kue/lib/queue/worker');

var oldFn = worker.prototype.process;
worker.prototype.process = function(job, fn) {
    var self = this;
    var args = arguments;

    var domain = require('domain').create();
    domain.on('error', function(err){
        self.failed(job, err, fn);
    });

    domain.run(function() {
        return oldFn.apply(self, args);
    });
};