RabbitMQというかRubyのAMQPライブラリメモ

どう考えても現在どのくらいのキューに貯まっているかは見たいですよね。

require 'rubygems'
require 'amqp'
require 'mq'

AMQP.start(:host =>　'localhost') do
  MQ.queue("piyo").status{ |num_msg, num_csm| 
    puts num_msg # キューに貯まっているメッセージ数
    puts num_csm # 待機しているコンシューマ数
  }
  AMQP.stop { EM.stop }
end