incoming.rb

      
      # lib/augury/queues/incoming.rb
      
      def self.push(messages)
        messages = normalize_and_validate(messages)

        messages.each do |msg|
          # insert message into mongo collection
          collection.insert(msg.inspect)
          
          # I will encapsulate this code. It is just a test.
          store = Augury.collections.stores.find({ "_id" => msg["store_id"] })
          msg_key = msg['key'].gsub(':', '_')
          # [customer].[server].[source].[msg].incoming
          Augury.statsd.increment "#{store['permalink']}.#{Augury.server_name}.#{msg['source']}.#{msg_key}.incoming"
        end

        Augury.statsd.count "queues.incoming", messages.count
      end