如何使用Java或Scala在sidekiq中排隊工作

Question

我在ruby運行中有一個sidekiq安裝，我想從Scala/Java系統中排隊工作。我怎樣才能做到這一點？這是我的工作人員：

class MyWorker 
    include Sidekiq::Worker 

    def perform(param) 
     puts "processing #{param}" 
     # ... 
    end 
end 

我試圖用jesque，但它不工作。這裏是jesque代碼我想使用：

val config = new ConfigBuilder().build(); 

val job = new Job("MyWorker", Array("my param")) 
val client = new ClientImpl(config); 
client.enqueue("default", job); 
client.end(); 

Answer 1

確保您使用的是同一個命名空間中的Ruby和Java的：

要Jesque配置命名空間，用途：

val config = new ConfigBuilder().withNamespace("you_namespace").build() 

要在ruby中配置命名空間，請在config/inititalizers內部創建sidekiq.rb目錄：

Sidekiq.configure_client do |config| 
    config.redis = { :namespace => 'you_namespace' } 
end