Module: Osbourne::Services::QueueProvisioner

Included in:
Osbourne
Defined in:
lib/osbourne/services/queue_provisioner.rb

Instance Method Summary collapse

Instance Method Details

#provision_worker_queues ⇒ Object 



6
7
8
9
10
11
12
13
 
# 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