Contents

# encoding: utf-8

module Rollbar
  class Sidekiq
    PARAM_BLACKLIST = %w[backtrace error_backtrace error_message error_class]

    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) }
      scope = { :request => { :params => params } }

      Rollbar.scope(scope).error(e, :use_exception_level_filters => true)
    end

    def self.skip_report?(msg_or_context, e)
      msg_or_context.is_a?(Hash) && msg_or_context["retry"] && msg_or_context["retry_count"] < ::Rollbar.configuration.sidekiq_threshold
    end

    def call(worker, msg, queue)
      yield
    rescue Exception => e
      Rollbar::Sidekiq.handle_exception(msg, e)
      raise
    end
  end
end

Sidekiq.configure_server do |config|
  if Sidekiq::VERSION < '3'
    config.server_middleware do |chain|
      chain.add Rollbar::Sidekiq
    end
  else
    config.error_handlers << Proc.new do |e, context|
      Rollbar::Sidekiq.handle_exception(context, e)
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
rollbar-2.6.1	lib/rollbar/sidekiq.rb
rollbar-2.6.0	lib/rollbar/sidekiq.rb