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)