Class: QC::Worker

Inherits:
Object
  • Object
show all
Defined in:
lib/queue_classic_batches/worker.rb

Instance Method Summary collapse

Instance Method Details

#process(queue, job) ⇒ Object 



6
7
8
9
10
11
12
13
 
# File 'lib/queue_classic_batches/worker.rb', line 6

def process(queue, job)
  result = qc_base_process queue, job
  if job[:batch_id]
    #note, for errors if the worker doesn't delete the job in handle_failure, this never fires
    QC::Batches::Batch.complete_if_finished job[:batch_id]
  end
  return result
end

#qc_base_process ⇒ Object 



4
 
# File 'lib/queue_classic_batches/worker.rb', line 4

alias_method :qc_base_process, :process