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