我有一个像这样的工人：
class MassDispatchServiceWorker
include Sidekiq::Worker
sidekiq_options queue: :bulk
def perform(message_params)
DispatchService.new(message_params).dispatch!
end
end
但是，我需要相同的确切方法，但需要将队列作为变量传递。有时我希望队列很大，其他时候我还需要其他东西。使用sidekiq可以吗？
使用Sidekiq::ClientAPI。
Sidekiq::Client.push('class' => MassDispatchServiceWorker, 'args' => [], 'queue' => whatever)
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句