module Osbourne::Services::QueueProvisioner

Public Instance Methods

provision_worker_queues() click to toggle source
# File lib/osbourne/services/queue_provisioner.rb, line 6
def provision_worker_queues
  Dir[File.expand_path("app/workers/**/*.rb")].each {|f| require f }
  return if Osbourne.test_mode?

  Osbourne.logger.info "[Osbourne] Workers found: #{Osbourne::WorkerBase.descendants.map(&:name).join(', ')}"
  Osbourne.logger.info "[Osbourne] Provisioning queues for all workers"
  Osbourne::WorkerBase.descendants.each(&:provision)
end