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

당신이 루비와 자바 모두 같은 네임 스페이스를 사용하고 있는지 확인하십시오 :

이 Jesque에서 네임 스페이스를 구성하려면 다음을 사용

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

루비에서 네임 스페이스를 구성하려면 config/inititalizers 디렉토리 안에 sidekiq.rb를 만듭니다.

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