lib/q4m.rb in q4m-0.0.7 vs lib/q4m.rb in q4m-0.0.8

- old
+ new

@@ -22,16 +22,15 @@ # # - Locks the queue. # - Executes the latest job. # - Restores the queue so other worker can execute a process. # - def run terminate = false + def run return unless @has_jobs queue_wait @log.info("Executing: #{latest_job.inspect}") execute latest_job queue_end - shutdown if terminate nil end # Shuts down the worker #