undefined method `receive_status' for nil:NilClass (NoMethodError) during queue.status

[thobruk]

The following generates the error:

AMQP.start(:host => '127.0.0.1') do |connection|
#  connection =
  channel  = AMQP::Channel.new(connection)
  exchange = channel.direct("")
  queue    = channel.queue("indexer_queue", {:durable => true}).bind(exchange)

EM.add_periodic_timer(5) {
    queue.status do |num_messages, num_consumers|
      puts "msgs:#{num_messages}"
    end
}

end

/home/bthomas/.rvm/gems/ruby-1.9.2-p290/gems/amqp-0.7.1/lib/amqp/channel.rb:864:in `handle_method': undefined method `receive_status' for nil:NilClass (NoMethodError)
    from /home/bthomas/.rvm/gems/ruby-1.9.2-p290/gems/amqp-0.7.1/lib/amqp/channel.rb:792:in `process_frame'

etc...

How am I supposed to correctly check queue status ? Thanks ! Is queue.status an EM event callback ?

[thobruk]

By the way queue.status with a block feels like a really wierd way to get status.

[michaelklishin]

That documentation is not for 0.7.x but for 0.8.0.RCs. AMQP::Queue#status with a block has been around since day 1 of the gem (for 3 years now) so removing it is not an option. Also, despite many pseudo-synchronous features, amqp gem is fully async and the status operation itself is async.

[michaelklishin]

0.7.2 was out yesterday, please try it and reopen if necessary. The code looks very reasonable but 0.7.x and 0.6.x series have plenty of limitations.

[michaelklishin]

I just learned that

gem install amqp --pre

now installs 0.7.2 for some reason. Investigating…

[thobruk]

I still get that error with 0.7.2. I have to drop the .bind(exchange) in order to prevent another error.

[michaelklishin]

Yes, I am able to reproduce it on 0.7.x. I don't see any "other errors" but default exchange is automatically bound to all queues so there is no need to #bind.

I have a solution, adding a test now. 0.7.3 will be out within an hour.

[michaelklishin]

0.7.3 is pushed to rubygems.org

[thobruk]

Works a charm ! Thanks for the very quick response.