kwando

class MessagingStatsService
  include TorqueBox::Injectors
  def start
    Thread.new do
      until @done
        queues.each do |queue|
          counter = org.hornetq.api.core.management.MessageCounterInfo.from_json(queue.list_message_counter)
          puts "Queue #{queue.name} count: #{counter.count} countDelta: #{counter.count_delta} depth: #{counter.depth} depth_delta: #{counter.depth_delta}"
          sleep 10
        end