Module: Droid::QueueMethods

Included in:: Droid

Defined in:: lib/droid/queue.rb

Instance Method Summary collapse

Instance Method Details

#listener(exchange_name, opts = {}) ⇒ `Object`



141
142
143

# File 'lib/droid/queue.rb', line 141

def listener(exchange_name, opts={})
  ListenQueue.new(exchange_name, opts)
end

#worker(queue_name, opts = {}) ⇒ `Object`



137
138
139

# File 'lib/droid/queue.rb', line 137

def worker(queue_name, opts={})
  WorkerQueue.new(queue_name, opts)
end