Sha256: 4e1c3f3253ce69c6e69fafbedbdc35955b4c8d2d80ca63b356234f3c8e4eb1d7
Contents?: true
Size: 1.31 KB
Versions: 14
Compression:
Stored size: 1.31 KB
Contents
require 'honeybadger/plugin'
require 'honeybadger'
module Honeybadger
module Plugins
module Sidekiq
class Middleware
def call(worker, msg, queue)
Honeybadger.context.clear!
klass = msg['wrapped'.freeze] || msg['class'.freeze]
Honeybadger::Trace.instrument("#{klass}#perform", { :source => 'sidekiq'.freeze, :jid => msg['jid'.freeze], :class => klass }) do
yield
end
end
end
Plugin.register do
requirement { defined?(::Sidekiq) }
execution do
::Sidekiq.configure_server do |sidekiq|
sidekiq.server_middleware do |chain|
chain.add Middleware
end
end
if defined?(::Sidekiq::VERSION) && ::Sidekiq::VERSION > '3'
::Sidekiq.configure_server do |sidekiq|
sidekiq.error_handlers << lambda {|ex, params|
return if params['retry'.freeze] && params['retry_count'.freeze].to_i < config[:'sidekiq.attempt_threshold'].to_i
opts = {parameters: params}
opts[:component] = params['wrapped'.freeze] || params['class'.freeze] if config[:'sidekiq.use_component']
Honeybadger.notify_or_ignore(ex, opts)
}
end
end
end
end
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems