def queue_status
h = HighLine.new
queue_status = [h.color("VNode", :bold), h.color("Messages", :bold), h.color("Consumers", :bold)]
total_messages = 0
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)
status = q.status
queue_status << vnode.to_s << status[:message_count].to_s << status[:consumer_count].to_s
total_messages += status[:message_count]
end
puts " total messages: #{total_messages}"
puts
puts h.list(queue_status, :columns_across, 3)
ensure
amqp_client.stop if defined?(amqp_client) && amqp_client
end