ruby - 如何使用 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​​ 中配置命名空间，请在 dir 中创建 sidekiq.rb config/inititalizers：

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