lib/backburner/allq_wrapper.rb in backburner-allq-1.0.14 vs lib/backburner/allq_wrapper.rb in backburner-allq-1.0.16

@@ -11,17 +11,19 @@
       @allq_wrapper = allq_wrapper
     end
 
     def watch
       Thread.new do
-        ran = false
-        job = @allq_wrapper.get(@tube_name)
-        if job.body
-          perform(job)
-          ran = true
+        loop do
+          ran = false
+          job = @allq_wrapper.get(@tube_name)
+          if job.body
+            perform(job)
+            ran = true
+          end
+          # Wait if nothing returned
+          sleep(rand() * 3) unless ran
         end
-        # Wait if nothing returned
-        sleep(rand() * 3) unless ran
       end
     end
   end
 
   class AllQJob