Sha256: 8f75b12cd0da3afeb9c2811260bb6fd893bbfd9a8a31a4e593e42625c4965f1c

Contents?: true

Size: 1.12 KB

Versions: 5

Compression:

Stored size: 1.12 KB

Contents

require 'honeybadger/plugin'
require 'honeybadger/ruby'

module Honeybadger
  module Plugins
    module Sidekiq
      class Middleware
        def call(worker, msg, queue)
          Honeybadger.context.clear!
          yield
        end
      end

      Plugin.register do
        requirement { defined?(::Sidekiq) }

        execution do
          ::Sidekiq.configure_server do |sidekiq|
            sidekiq.server_middleware do |chain|
              chain.prepend Middleware
            end
          end

          if defined?(::Sidekiq::VERSION) && ::Sidekiq::VERSION > '3'
            ::Sidekiq.configure_server do |sidekiq|
              sidekiq.error_handlers << lambda {|ex, params|
                job = params[:job] || params
                return if job['retry'.freeze] && job['retry_count'.freeze].to_i < config[:'sidekiq.attempt_threshold'].to_i
                opts = {parameters: params}
                opts[:component] = job['wrapped'.freeze] || job['class'.freeze] if config[:'sidekiq.use_component']
                Honeybadger.notify(ex, opts)
              }
            end
          end
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version Path
honeybadger-4.1.0 lib/honeybadger/plugins/sidekiq.rb
honeybadger-4.0.0 lib/honeybadger/plugins/sidekiq.rb
honeybadger-3.3.1 lib/honeybadger/plugins/sidekiq.rb
honeybadger-3.4.0.beta1 lib/honeybadger/plugins/sidekiq.rb
honeybadger-3.3.0 lib/honeybadger/plugins/sidekiq.rb