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