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