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