Sha256: b33dc06a1a9f989f23be81da9c98fe01d4afe5b2411dc60507fa0e8462b5d3cb
Contents?: true
Size: 1.36 KB
Versions: 6
Compression:
Stored size: 1.36 KB
Contents
require 'sidekiq'
module Bugsnag
##
# Extracts and attaches Sidekiq job and queue information to an error report
class Sidekiq
FRAMEWORK_ATTRIBUTES = {
:framework => "Sidekiq"
}
def initialize
Bugsnag.configuration.internal_middleware.use(Bugsnag::Middleware::Sidekiq)
Bugsnag.configuration.app_type = "sidekiq"
Bugsnag.configuration.default_delivery_method = :synchronous
end
def call(worker, msg, queue)
begin
# store msg/queue in thread local state to be read by Bugsnag::Middleware::Sidekiq
Bugsnag.configuration.set_request_data :sidekiq, { :msg => msg, :queue => queue }
yield
rescue Exception => ex
raise ex if [Interrupt, SystemExit, SignalException].include? ex.class
Bugsnag.notify(ex, true) do |report|
report.severity = "error"
report.severity_reason = {
:type => Bugsnag::Report::UNHANDLED_EXCEPTION_MIDDLEWARE,
:attributes => FRAMEWORK_ATTRIBUTES
}
end
raise
ensure
Bugsnag.configuration.clear_request_data
end
end
end
end
::Sidekiq.configure_server do |config|
config.server_middleware do |chain|
if Gem::Version.new(Sidekiq::VERSION) >= Gem::Version.new('3.3.0')
chain.prepend ::Bugsnag::Sidekiq
else
chain.add ::Bugsnag::Sidekiq
end
end
end
Version data entries
6 entries across 6 versions & 1 rubygems