class Roundhousekiq::WorkerDefinition

Attributes

exchange[R]
queue[R]

Public Class Methods

new() click to toggle source
# File lib/roundhousekiq/worker_definition.rb, line 6
def initialize
  @exchange = {}
  @queue = {}
end

Public Instance Methods

exchange_name=(name) click to toggle source
# File lib/roundhousekiq/worker_definition.rb, line 11
def exchange_name=(name)
  exchange[:name] = name
end
exchange_type=(type) click to toggle source
# File lib/roundhousekiq/worker_definition.rb, line 15
def exchange_type=(type)
  exchange[:type] = type
end
queue_name=(name) click to toggle source
# File lib/roundhousekiq/worker_definition.rb, line 19
def queue_name=(name)
  name ||= '' # Default name to empty string

  queue[:name]        = name
  queue[:durable]     = name != ''
  queue[:auto_delete] = name == ''
end
routing_key=(key) click to toggle source
# File lib/roundhousekiq/worker_definition.rb, line 27
def routing_key=(key)
  queue[:routing_key] = key
end