class Sidekiq::Recursive::ArgumentQueue
Public Class Methods
pop(worker)
click to toggle source
# File lib/sidekiq/recursive/argument_queue.rb, line 10 def pop(worker) arguments_queue_name = generate_arguments_queue_name(worker) redis_client.lpop(arguments_queue_name) end
push(worker, arguments)
click to toggle source
# File lib/sidekiq/recursive/argument_queue.rb, line 3 def push(worker, arguments) arguments_queue_name = generate_arguments_queue_name(worker) redis_client.rpush(arguments_queue_name, arguments) true end
Private Class Methods
generate_arguments_queue_name(worker)
click to toggle source
# File lib/sidekiq/recursive/argument_queue.rb, line 17 def generate_arguments_queue_name(worker) worker.to_s end
redis_client()
click to toggle source
# File lib/sidekiq/recursive/argument_queue.rb, line 21 def redis_client Sidekiq.redis { |conn| conn } end