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