lib/amqp/queue.rb in amqp-0.7.2 vs lib/amqp/queue.rb in amqp-0.7.3

- old
+ new

@@ -425,9 +425,10 @@ def status(opts = {}, &blk) return @status if opts.empty? && blk.nil? @on_status = blk @mq.callback { + @mq.queues_awaiting_declare_ok.push(self) @mq.send Protocol::Queue::Declare.new({ :queue => name, :passive => true }.merge(opts)) } self end