# File lib/amqp/queue.rb, line 428 def receive_status(declare_ok) @name = declare_ok.queue @status = :finished if self.callback # compatibility for a common case when callback only takes one argument if self.callback.arity == 1 self.callback.call(self) else self.callback.call(self, declare_ok.message_count, declare_ok.consumer_count) end end if @on_status m, c = declare_ok.message_count, declare_ok.consumer_count @on_status.call *(@on_status.arity == 1 ? [m] : [m, c]) @on_status = nil end end