如何使用Java或Scala在sidekiq中为作业排队

Question

我在ruby中安装了sidekiq，我想从Scala / Java系统中为作业排队。我该怎么做？这是我的工人：

class MyWorker
    include Sidekiq::Worker

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

我试着使用杰斯克，但它不起作用。下面是我试图使用的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中配置命名空间，请在sidekiq.rb dir中创建config/inititalizers：

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