class Discobolo::Client

Public Instance Methods

dequeue(queue) click to toggle source
# File lib/discobolo/client.rb, line 16
def dequeue(queue)
  call("DEQUEUE", queue)
end
enqueue(queue) click to toggle source
# File lib/discobolo/client.rb, line 20
def enqueue(queue)
  call("ENQUEUE", queue)
end
info() click to toggle source
# File lib/discobolo/client.rb, line 42
def info
  call("INFO")
end
jscan(queue, page=0, count=30) click to toggle source
# File lib/discobolo/client.rb, line 29
def jscan(queue, page=0, count=30)
  jobs = []
  Discobolo::Config.client.call("JSCAN", page, "COUNT", count, "QUEUE" , queue, "REPLY", "all").each do |job|
    next if job.is_a? String
    next if job.empty?
    job.each do |j|
      jobs << { results: Hash[*j] }
    end
  end.compact
  jobs
  #binding.pry
end
queue_lenght(queue) click to toggle source
# File lib/discobolo/client.rb, line 12
def queue_lenght(queue)
  call("QLEN", queue)
end
queue_stat(queue) click to toggle source
# File lib/discobolo/client.rb, line 24
def queue_stat(queue)
  Discobolo::Config.logger.error("QSTAT not implemented yet")
  #call("QSTAT", queue)
end
show(jobid) click to toggle source
# File lib/discobolo/client.rb, line 4
def show(jobid)
  Hash[ *call("SHOW", jobid)]
end
working(jobid) click to toggle source
# File lib/discobolo/client.rb, line 8
def working(jobid)
  call("WORKING", jobid)
end