def queue_depth
h = HighLine.new
message_counts = []
amqp_client = Bunny.new(Expander.config.amqp_config)
amqp_client.start
0.upto(VNODES - 1) do |vnode|
q = amqp_client.queue("vnode-#{vnode}", :durable => true)
message_counts << q.status[:message_count]
end
total_messages = message_counts.inject(0) { |sum, count| sum + count }
max = message_counts.max
min = message_counts.min
avg = total_messages.to_f / message_counts.size.to_f
puts " total messages: #{total_messages}"
puts " average queue depth: #{avg}"
puts " max queue depth: #{max}"
puts " min queue depth: #{min}"
ensure
amqp_client.stop if defined?(amqp_client) && amqp_client
end