Class: Cloudist::ReplyQueue

Inherits:
Queues::BasicQueue show all
Defined in:
lib/cloudist/queues/reply_queue.rb

Instance Attribute Summary

Attributes inherited from Queues::BasicQueue

#channel, #exchange, #options, #prefetch, #queue, #queue_name

Instance Method Summary collapse

Methods inherited from Queues::BasicQueue

#destroy, #inspect, #log, #print_status, #publish, #publish_to_q, #setup, #setup_exchange, #subscribe, #tag, #teardown

Constructor Details

#initialize(queue_name, options = {}) ⇒ ReplyQueue

Returns a new instance of ReplyQueue.



3
4
5
6
7
8
9
10
 
# File 'lib/cloudist/queues/reply_queue.rb', line 3

def initialize(queue_name, options={})
  options[:auto_delete] = true
  options[:nowait] = false

  @prefetch = Cloudist.listener_prefetch

  super(queue_name, options)
end