1 2 3 4 5 6 7 8 9 10 11 12 13 14 15
module BackburnerJobsManager def clear_jobs Backburner::Worker.connection.tubes.all.map &:clear end def start_workers @thread = Thread.new { Backburner.work "active-jobs-default" } end def stop_workers @thread.kill end end