queue_depth.rb

require 'mq'
require 'pp'

EM.run {

  def log *args
    p args
  end

  mq = MQ.new

  spam = mq.queue("my spam").bind(mq.topic("spam"))

  EM.add_periodic_timer(5) do
    spam.status { |m,c|
      puts m
      puts c
    }
  end


  spam.subscribe { |i|
    log :read_spam, i
  }
  
}