Module: QC::Api

Included in:
QC
Defined in:
lib/queue_classic/api.rb

Instance Method Summary collapse

Instance Method Details

#delete(job) ⇒ Object 



12
13
14
 
# File 'lib/queue_classic/api.rb', line 12

def delete(job)
  Queue.delete(job)
end

#dequeue ⇒ Object 



8
9
10
 
# File 'lib/queue_classic/api.rb', line 8

def dequeue
  Queue.dequeue
end

#enqueue(job, *params) ⇒ Object 



4
5
6
 
# File 'lib/queue_classic/api.rb', line 4

def enqueue(job,*params)
  Queue.enqueue(job,params)
end

#logging_enabled? ⇒ Boolean

Returns:

  • (Boolean) 


31
32
33
 
# File 'lib/queue_classic/api.rb', line 31

def logging_enabled?
  true
end

#queue_length ⇒ Object 



16
17
18
 
# File 'lib/queue_classic/api.rb', line 16

def queue_length
  Queue.length
end

#work(job) ⇒ Object 



20
21
22
23
24
25
26
27
28
29
 
# File 'lib/queue_classic/api.rb', line 20

def work(job)
  klass   = job.klass
  method  = job.method
  params  = job.params

  klass.send(method,params)
  delete(job)
rescue ArgumentError => e
  puts "ArgumentError: #{e.inspect}"
end