module Barbeque::Worker
Constants
- DEFAULT_QUEUE
Public Class Methods
new()
click to toggle source
# File lib/barbeque/worker.rb, line 36 def initialize queue_name = ENV['BARBEQUE_QUEUE'] || DEFAULT_QUEUE queue = Barbeque::JobQueue.find_by!(name: queue_name) @command = case worker_id when 0 ExecutionPoller.new(queue) when 1 RetryPoller.new(queue) else Runner.new(queue) end end
run( worker_type: 'process', workers: 4, daemonize: false, log: $stdout, log_level: :info, pid_path: '/tmp/barbeque_worker.pid', supervisor: true )
click to toggle source
# File lib/barbeque/worker.rb, line 13 def self.run( worker_type: 'process', workers: 4, daemonize: false, log: $stdout, log_level: :info, pid_path: '/tmp/barbeque_worker.pid', supervisor: true ) options = { worker_type: worker_type, workers: workers, daemonize: daemonize, log: log, log_level: log_level, pid_path: pid_path, supervisor: supervisor, } worker = ServerEngine.create(nil, Barbeque::Worker, options) worker.run end
Public Instance Methods
execute_command()
click to toggle source
# File lib/barbeque/worker.rb, line 68 def execute_command @command.run end
run()
click to toggle source
# File lib/barbeque/worker.rb, line 51 def run $0 = "barbeque-worker (worker_id=#{worker_id} command=#{@command.class.name})" until @stop begin execute_command rescue => e Barbeque::ExceptionHandler.handle_exception(e) end Barbeque::ExceptionHandler.clear_context end end
stop()
click to toggle source
# File lib/barbeque/worker.rb, line 63 def stop @stop = true @command.stop end