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