introduce worker.id

Automattic · Jun 1, 2014 · 0dd922f · 0dd922f
1 parent 657fd45
commit 0dd922f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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);
         });