my_task.rake

desc "all in one"
task :all_in_one => :environment do
   #q here is a message q.  Assume it receives messages at the rate of 10/second
   q.subscribe(:block => true) do |delivery_info, properties, body|  
    #process the message (body)
    
    puts "I got a message: #{body}"
    
    #I'd like every 10 seconds to output Total Messages Received: 13021
   end
end