Take the whole RQ down if the web child goes down

bwitt · Jan 23, 2015 · f282ca2 · f282ca2
1 parent c58d4ef
commit f282ca2
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/code/queuemgr.rb b/code/queuemgr.rb
@@ -404,7 +404,14 @@ def run!
             pid, status = Process.wait2(-1, Process::WNOHANG) rescue nil
             if pid
               worker = @queues.values.find { |o| o.pid == pid }
-              handle_worker_close(worker, status) if worker
+              if worker
+                handle_worker_close(worker, status)
+              elsif @web_server == pid
+                # TODO: Try to restart the web server? How many times?
+                $log.fatal("The web server has died. Terminating this RQ instance.")
+                @web_server = nil
+                shutdown!
+              end
             end
 
           else