如何使用 Java 或 Scala 在 sidekiq 中排队工作答案

【问题标题】：How to enqueue a job in sidekiq with Java or Scala如何使用 Java 或 Scala 在 sidekiq 中排队工作
【发布时间】：2014-02-24 10:03:01
【问题描述】：

我在运行 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();

【问题讨论】：

标签： ruby scala resque sidekiq jesque

【解决方案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

【讨论】：