Class: Droid::ListenQueue
Instance Attribute Summary
Attributes inherited from BaseQueue
#ex, #mq, #opts, #q, #queue_name
Instance Method Summary collapse
-
#initialize(exchange_name, opts = {}) ⇒ ListenQueue
constructor
A new instance of ListenQueue.
Methods inherited from BaseQueue
#destroy, #log, #setup, #subscribe, #tag, #teardown, #temp?
Constructor Details
#initialize(exchange_name, opts = {}) ⇒ ListenQueue
Returns a new instance of ListenQueue.
99 100 101 102 103 |
# File 'lib/droid/queue.rb', line 99 def initialize(exchange_name, opts={}) opts[:exchange_name] = exchange_name queue_name = opts.delete(:queue) || Droid::Utils.generate_queue(exchange_name) super(queue_name, opts) end |