Pass worker context to processors so they can pause/resume workers.

behrad · behrad · commit c20c95886564 · 2014-01-26T12:53:09.000+03:30
diff --git a/lib/queue/worker.js b/lib/queue/worker.js
@@ -159,32 +159,33 @@ Worker.prototype.process = function (job, fn) {
 //        process.nextTick( function(){
             fn(
                 job,
-                /**
-                 * @author behrad
-                 * @pause: let the processor to tell worker not to continue processing new jobs
-                 */
-                function (err, pause) {
+                function (err) {
                     if (err) {
                         return self.failed(job, err, fn);
                     }
                     job.complete();
                     job.set('duration', job.duration = new Date - start);
                     self.emit('job complete', job);
                     events.emit(job.id, 'complete');
-                    if (pause) {
-                        self.queue.shutdown(function () {
-                        }, pause===true?5000:Number(pause), self.type);
-                    }
                     self.job = null;
                     self.start(fn);
-                },
-                /**
-                 * @author behrad
-                 * @pause: let the processor to trigger restart for they job processing
-                 */
-                function () {
-                    if (self.resume()) {
-                        self.start(fn);
+                },{
+                    /**
+                     * @author behrad
+                     * @pause: let the processor to tell worker not to continue processing new jobs
+                     */
+                    pause: function( fn, timeout ){
+                        timeout = timeout || 5000;
+                        self.queue.shutdown( fn, Number(timeout), self.type);
+                    },
+                    /**
+                     * @author behrad
+                     * @pause: let the processor to trigger restart for they job processing
+                     */
+                    resume: function () {
+                        if (self.resume()) {
+                            self.start(fn);
+                        }
                     }
                 }
             );
