class Librato::Sidekiq::ClientMiddleware
Public Class Methods
reconfigure()
click to toggle source
# File lib/librato-sidekiq/client_middleware.rb, line 4 def self.reconfigure # puts "Reconfiguring with: #{options}" ::Sidekiq.configure_client do |config| config.client_middleware do |chain| chain.remove self chain.add self, options end end end
Protected Instance Methods
track(tracking_group, stats, worker_instance, msg, queue, elapsed)
click to toggle source
# File lib/librato-sidekiq/client_middleware.rb, line 16 def track(tracking_group, stats, worker_instance, msg, queue, elapsed) tracking_group.increment 'queued' return unless allowed_to_submit queue, worker_instance # puts "doing Librato insert" tracking_group.group queue.to_s do |q| q.increment 'queued' # using something like User.delay.send_email invokes # a class name with slashes. remove them in favor of underscores q.group msg['class'].underscore.gsub('/', '_') do |w| w.increment 'queued' end end end