lib/cloudist/queues/reply_queue.rb in cloudist-0.4.4 vs lib/cloudist/queues/reply_queue.rb in cloudist-0.5.0

- old
+ new

@@ -1,25 +1,25 @@ module Cloudist class ReplyQueue < Cloudist::Queues::BasicQueue def initialize(queue_name, options={}) options[:auto_delete] = true options[:nowait] = false - + @prefetch = Cloudist.listener_prefetch - + super(queue_name, options) end - + # def subscribe(&block) # super do |request| # yield request if block_given? # teardown # end # end - + # def teardown # queue.delete # super # end - + end end