output

08:41:30,006 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2) Stats for Queue /queues/foo
08:41:30,006 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Paused: false
08:41:30,006 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Temporary: false
08:41:30,007 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Message Count: 0
08:41:30,007 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Delivering Count: 0
08:41:30,007 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Scheduled Count: 0
08:41:30,007 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Messages Added Since Creation: 6
08:41:30,007 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Consumer Count: 1
08:41:30,007 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Expiry Address: jms.queue.ExpiryQueue
08:41:30,007 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Dead Letter Address: jms.queue.DLQ
08:41:30,007 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Selector: 
08:41:30,007 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-1) Job executing!
08:41:30,008 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2) Stats for Queue /queues/torquebox/blah/tasks/torquebox_backgroundable
08:41:30,008 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Paused: false
08:41:30,008 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Temporary: false
08:41:30,008 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Message Count: 0
08:41:30,008 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Delivering Count: 0
08:41:30,008 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Scheduled Count: 0
08:41:30,010 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Messages Added Since Creation: 0
08:41:30,010 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Consumer Count: 1
08:41:30,011 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Expiry Address: jms.queue.ExpiryQueue
08:41:30,011 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Dead Letter Address: jms.queue.DLQ
08:41:30,012 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Selector: 
08:41:30,014 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2) Stats for Queue DLQ
08:41:30,014 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Paused: false
08:41:30,014 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Temporary: false
08:41:30,014 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Message Count: 0
08:41:30,014 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Delivering Count: 0
08:41:30,014 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Scheduled Count: 0
08:41:30,015 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Messages Added Since Creation: 0
08:41:30,015 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Consumer Count: 0
08:41:30,015 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Expiry Address: jms.queue.ExpiryQueue
08:41:30,015 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Dead Letter Address: jms.queue.DLQ
08:41:30,015 INFO  [stdout] (JobScheduler$blah-knob.yml_Worker-2)   Selector: 

stats_job.rb

class StatsJob
  include TorqueBox::Injectors

  def initialize
    hornetq_server = fetch('jboss.messaging.default')
    @management_service = hornetq_server.management_service
    @queue_control_class = org.hornetq.jms.management.impl.JMSQueueControlImpl.java_class
  end

  def run
    queues = @management_service.getResources(@queue_control_class)
    queues.each do |queue|
      puts <<-EOS
Stats for Queue #{queue.name}
  Paused: #{queue.paused?}
  Temporary: #{queue.temporary?}
  Message Count: #{queue.message_count}
  Delivering Count: #{queue.delivering_count}
  Scheduled Count: #{queue.scheduled_count}
  Messages Added Since Creation: #{queue.messages_added}
  Consumer Count: #{queue.consumer_count}
  Expiry Address: #{queue.expiry_address}
  Dead Letter Address: #{queue.dead_letter_address}
  Selector: #{queue.selector}
EOS
    end
  end

end