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
jobs_by_worker()
Alias for: jobs_by_class
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