class Roundhousekiq::Workers
Public Class Methods
definitions()
click to toggle source
# File lib/roundhousekiq/workers.rb, line 12 def definitions @@definitions ||= {} end
exchange_name_for(worker, name)
click to toggle source
# File lib/roundhousekiq/workers.rb, line 16 def exchange_name_for(worker, name) definition = definitions[worker] fail "Unknown worker class passed: #{worker}" unless definition definition.exchange_name = name end
exchange_type_for(worker, type)
click to toggle source
# File lib/roundhousekiq/workers.rb, line 22 def exchange_type_for(worker, type) definition = definitions[worker] fail "Unknown worker class passed: #{worker}" unless definition definition.exchange_type = type end
queue_name_for(worker, name)
click to toggle source
# File lib/roundhousekiq/workers.rb, line 28 def queue_name_for(worker, name) definition = definitions[worker] fail "Unknown worker class passed: #{worker}" unless definition definition.queue_name = name end
register(worker)
click to toggle source
# File lib/roundhousekiq/workers.rb, line 4 def register(worker) if definitions.key? worker warn "Worker class #{worker.to_s} already registered" end definitions[worker] = WorkerDefinition.new end
routing_key_for(worker, key)
click to toggle source
# File lib/roundhousekiq/workers.rb, line 34 def routing_key_for(worker, key) definition = definitions[worker] fail "Unknown worker class passed: #{worker}" unless definition definition.routing_key = key end