lib/cloudist/queues/reply_queue.rb in cloudist-0.4.1 vs lib/cloudist/queues/reply_queue.rb in cloudist-0.4.2
- old
+ new
@@ -1,11 +1,11 @@
module Cloudist
class ReplyQueue < Cloudist::Queues::BasicQueue
def initialize(queue_name, options={})
options[:auto_delete] = true
- options[:nowait] = true
+ options[:nowait] = false
- @prefetch = 2
+ @prefetch = 1
super(queue_name, options)
end
# def subscribe(&block)