Sha256: df4bdfe7e55058b7a7e82633ffaecf1fcf46ac5b4755085896e20e4fb83b2c39
Contents?: true
Size: 1.39 KB
Versions: 7
Compression:
Stored size: 1.39 KB
Contents
require 'rollbar/scrubbers/params'
module Rollbar
class Sidekiq
PARAM_BLACKLIST = %w[backtrace error_backtrace error_message error_class]
class ClearScope
def call(worker, msg, queue)
Rollbar.reset_notifier!
yield
end
end
def self.handle_exception(msg_or_context, e)
return if skip_report?(msg_or_context, e)
params = msg_or_context.reject{ |k| PARAM_BLACKLIST.include?(k) }
scrubbed_params = scrub_params(params)
scope = {
:request => { :params => scrubbed_params },
:framework => "Sidekiq: #{::Sidekiq::VERSION}"
}
if params.is_a?(Hash)
scope[:context] = params['class']
scope[:queue] = params['queue']
end
Rollbar.scope(scope).error(e, :use_exception_level_filters => true)
end
def self.scrub_params(params)
options = {
:params => params,
:config => Rollbar.configuration.scrub_fields
}
Rollbar::Scrubbers::Params.call(options)
end
def self.skip_report?(msg_or_context, e)
msg_or_context.is_a?(Hash) && msg_or_context["retry"] &&
msg_or_context["retry_count"] && msg_or_context["retry_count"] < ::Rollbar.configuration.sidekiq_threshold
end
def call(worker, msg, queue)
Rollbar.reset_notifier!
yield
rescue Exception => e
Rollbar::Sidekiq.handle_exception(msg, e)
raise
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems