Module: Droid::QueueMethods

Included in:: Droid

Defined in:: lib/droid/queue.rb

Instance Method Summary collapse

Instance Method Details

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



140
141
142

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

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

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



136
137
138

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

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