Method: Ungulate::Server#run

Defined in:
lib/ungulate/server.rb

#run ⇒ Object 



24
25
26
27
28
29
30
31
32
33
 
# File 'lib/ungulate/server.rb', line 24

def run
  @logger.info "Checking for job on #{@queue.name}"
  message = @queue.receive

  if message
    success = @job_processor.process(message.to_s)
    message.delete
    success
  end
end