bnorton/micro_q

module MicroQ
  module Middleware
    module Server
      class Statistics
        include MicroQ::Middleware::Util

        PERFORMED = proc {|klass| klass ? "messages:#{klass}:performed" : 'messages:performed' }

        def call(_, message)
          stats(message)
          yield
        end

        private

        def stats(msg)
          stats_incr(msg, PERFORMED, "queues:#{msg['queue']}:performed")
        end
      end
    end
  end
end