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