lib/cloudist/reply_queue.rb in cloudist-0.0.2 vs lib/cloudist/reply_queue.rb in cloudist-0.0.3
- old
+ new
@@ -1,8 +1,9 @@
module Cloudist
class ReplyQueue < Cloudist::BasicQueue
def initialize(queue_name, opts={})
opts[:auto_delete] = true
+ opts[:nowait] = false
super
end
def setup(key = nil)
@mq = MQ.new