Method: Pgq::Worker#run

Defined in:
lib/pgq/worker.rb

#run ⇒ Object 



76
77
78
79
80
81
82
83
 
# File 'lib/pgq/worker.rb', line 76

def run
  logger.info "Worker for (#{@queues.join(",")}) started"

  loop do
    processed_count = process_batch
    sleep(@sleep_time) if processed_count == 0
  end
end