class Message::Filters::Benchmarking
Public Instance Methods
call(filter, job, action)
click to toggle source
# File lib/message/filters/benchmarking.rb, line 5 def call(filter, job, action) lambda do |msg| return filter.call(msg) unless action == :process ret = nil Message.log(:info) { "#{job.name}: processing one message"} s = Benchmark.realtime do ret = filter.call(msg) end Message.log(:info) { "#{job.name}: processed in #{(1000 * s).to_i}ms" } ret end end