diff --git a/lib/kue.js b/lib/kue.js index 39862e49..48c7e70a 100755 --- a/lib/kue.js +++ b/lib/kue.js @@ -217,6 +217,7 @@ Queue.prototype.process = function (type, n, fn) { while (n--) { var worker = new Worker(this, type).start(fn); + worker.id = [process.pid,type,self.workers.length+1].join('-'); worker.on('error', function (err) { self.emit('error', err); });