Sidekiq:如何将队列作为变量传递给工作人员

Question

我有一个这样的 worker :

class MassDispatchServiceWorker
  include Sidekiq::Worker
  sidekiq_options queue: :bulk

  def perform(message_params)
    DispatchService.new(message_params).dispatch!
  end
end

但是我需要完全相同的方法，但需要将队列作为变量传递。有时我希望队列很庞大，有时我需要其他东西。 sidekiq 可以吗？

Answer 1

还有一种方式:

MyWorker.set(queue: 'foo').perform_async(1)

来自 https://github.com/mperham/sidekiq/issues/2152#issuecomment-290376790