diff options
Diffstat (limited to 'activejob/test/support/integration/adapters/qu.rb')
| -rw-r--r-- | activejob/test/support/integration/adapters/qu.rb | 14 |
1 files changed, 14 insertions, 0 deletions
diff --git a/activejob/test/support/integration/adapters/qu.rb b/activejob/test/support/integration/adapters/qu.rb new file mode 100644 index 0000000000..12d063ea0d --- /dev/null +++ b/activejob/test/support/integration/adapters/qu.rb @@ -0,0 +1,14 @@ +module QuJobsManager + def clear_jobs + Qu.clear "active_jobs_default" + end + + def start_workers + @thread = Thread.new { Qu::Worker.new("active_jobs_default").start } + end + + def stop_workers + @thread.kill + end +end + |