class Quiq::Server

Public Instance Methods

run!() click to toggle source
# File lib/quiq/server.rb, line 12
def run!
  # Launch one worker per queue
  Quiq.queues.each do |queue|
    fork { Worker.new(queue).start }
  end

  # Launch scheduler for jobs to be performed at certain time
  fork { Scheduler.instance.start }

  # Set the process name
  Process.setproctitle("quiq master #{Quiq.configuration.path}")

  # TODO: handle graceful shutdowns
  Process.waitall
end