activejob/test/support/integration/adapters/backburner.rb


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