2015-06-01 92 views
0

我有一個工人,像這樣:Sidekiq:如何在隊列作爲變量傳遞到工人

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

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

但是我有需要,但在隊列中作爲一個變量來傳遞完全相同的方法。有時我希望隊列是批量的,其他時候我需要其他的東西。這可能與sidekiq?

回答

0

使用Sidekiq::Client API。

Sidekiq::Client.push('class' => MassDispatchServiceWorker, 'args' => [], 'queue' => whatever) 
+0

這似乎很醜陋:(是唯一的方法來做到這一點? –