[Rails] Sidekiq API

取得 Queue

Sidekiq::Queue.all 	# 所有的Queue
Sidekiq::Queue.new 	# "default" Queue
Sidekiq::Queue.new("mailer") # "mailer" Queue

查詢xx Queue裡面的Job

Sidekiq::Queue.new("mailer").find_all #所有"mailer" Queue 裡面的Jobs
Sidekiq::Queue.new("mailer").find(jid) #取得"mailer" Queue 特定 jid 的Job

其他

Sidekiq::Queue.new.size # 取得Job數量 => 4
Sidekiq::Queue.new.clear # 清除所有Job

Job操作

queue = Sidekiq::Queue.new("mailer")
queue.each do |job|
  job.klass # => 'MyWorker'
  job.args # => [1, 2, 3]
  job.jid # 'abcdef1234567890'
  job.delete #刪除
end

參考

1. Sidekiq API