module Sidekiq::Queues
Public Class Methods
[](queue)
click to toggle source
# File lib/sidekiq/testing.rb, line 177 def [](queue) jobs_by_queue[queue] end
clear_all()
click to toggle source
# File lib/sidekiq/testing.rb, line 205 def clear_all jobs_by_queue.clear jobs_by_class.clear end
clear_for(queue, klass)
click to toggle source
# File lib/sidekiq/testing.rb, line 200 def clear_for(queue, klass) jobs_by_queue[queue.to_s].clear jobs_by_class[klass].clear end
delete_for(jid, queue, klass)
click to toggle source
# File lib/sidekiq/testing.rb, line 195 def delete_for(jid, queue, klass) jobs_by_queue[queue.to_s].delete_if { |job| job["jid"] == jid } jobs_by_class[klass].delete_if { |job| job["jid"] == jid } end
jobs_by_class()
click to toggle source
# File lib/sidekiq/testing.rb, line 190 def jobs_by_class @jobs_by_class ||= Hash.new { |hash, key| hash[key] = [] } end
Also aliased as: jobs_by_worker
jobs_by_queue()
click to toggle source
# File lib/sidekiq/testing.rb, line 186 def jobs_by_queue @jobs_by_queue ||= Hash.new { |hash, key| hash[key] = [] } end
push(queue, klass, job)
click to toggle source
# File lib/sidekiq/testing.rb, line 181 def push(queue, klass, job) jobs_by_queue[queue] << job jobs_by_class[klass] << job end