Method: Asynchronic::Worker#start

Defined in:
lib/asynchronic/worker.rb

#start ⇒ Object 



12
13
14
15
16
17
18
19
20
 
# File 'lib/asynchronic/worker.rb', line 12

def start
  Asynchronic.logger.info('Asynchronic') { "Starting worker of #{queue_name} (#{Process.pid})" }

  Signal.trap('QUIT') { stop }

  listener.listen(queue) do |pid|
    environment.load_process(pid).execute
  end
end