saftey around queue shutdown

evantahler · Jul 15, 2016 · da894bf · da894bf
1 parent 47c6f2c
commit da894bf
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/initializers/resque.js b/initializers/resque.js
@@ -28,6 +28,11 @@ module.exports = {
         self.queue.connect(callback);
       },
 
+      stopQueue: function(callback){
+        if(api.resque.queue){ api.resque.queue.end(callback); }
+        else{ callback(); }
+      },
+
       startScheduler: function(callback){
         var self = this;
         var scheduler = NR.scheduler;
@@ -142,7 +147,7 @@ module.exports = {
   stop: function(api, next){
     api.resque.stopScheduler(function(){
       api.resque.stopMultiWorker(function(){
-        api.resque.queue.end(function(){
+        api.resque.stopQueue(function(){
           next();
         });
       });