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


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

module QueJobsManager
  def clear_jobs
    Que.clear!
  end

  def start_workers
    @thread = Thread.new do
      loop do
        Que::Job.work("active_jobs_default")
        sleep 0.5
      end
    end
  end

  def stop_workers
    @thread.kill
  end
end