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
#