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()

config/inititalizersRuby で名前空間を構成するには、 dir内に sidekiq.rb を作成します。

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