lchenay

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);