Sha256: 65e4b55e7e1ed4de1e9dbd265c83e598788cc76978be3ec3d15d7be1fc570a92
Contents?: true
Size: 1.28 KB
Versions: 13
Compression:
Stored size: 1.28 KB
Contents
require 'sidekiq'
module Bugsnag
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
13 entries across 13 versions & 1 rubygems