Sha256: 720d037fa6b82263eca3e86dd1665870670f0f45204a2fe2a26d5e013e95d354

Contents?: true

Size: 1.11 KB

Versions: 10

Compression:

Stored size: 1.11 KB

Contents

require 'shoryuken'

module Bugsnag
  ##
  # Extracts and attaches Shoryuken queue information to an error report
  class Shoryuken

    FRAMEWORK_ATTRIBUTES = {
      :framework => "Shoryuken"
    }

    def initialize
      Bugsnag.configure do |config|
        config.app_type ||= "shoryuken"
        config.default_delivery_method = :synchronous
      end
    end

    def call(_, queue, _, body)
      begin
        Bugsnag.before_notify_callbacks << lambda {|report|
          report.add_tab(:shoryuken, {
            queue: queue,
            body: body
          })
        }

        yield
      rescue Exception => ex
        Bugsnag.notify(ex, true) do |report|
          report.severity = "error"
          report.severity_reason = {
            :type => Bugsnag::Report::UNHANDLED_EXCEPTION_MIDDLEWARE,
            :attributes => Bugsnag::Shoryuken::FRAMEWORK_ATTRIBUTES
          }
        end
        raise
      ensure
        Bugsnag.configuration.clear_request_data
      end
    end
  end
end

::Shoryuken.configure_server do |config|
  config.server_middleware do |chain|
    chain.add ::Bugsnag::Shoryuken
  end
end

Version data entries

10 entries across 10 versions & 1 rubygems

Version Path
bugsnag-6.15.0 lib/bugsnag/integrations/shoryuken.rb
bugsnag-6.14.0 lib/bugsnag/integrations/shoryuken.rb
bugsnag-6.13.1 lib/bugsnag/integrations/shoryuken.rb
bugsnag-6.13.0 lib/bugsnag/integrations/shoryuken.rb
bugsnag-6.12.2 lib/bugsnag/integrations/shoryuken.rb
bugsnag-6.12.1 lib/bugsnag/integrations/shoryuken.rb
bugsnag-6.12.0 lib/bugsnag/integrations/shoryuken.rb
bugsnag-6.11.1 lib/bugsnag/integrations/shoryuken.rb
bugsnag-6.11.0 lib/bugsnag/integrations/shoryuken.rb
bugsnag-6.10.0 lib/bugsnag/integrations/shoryuken.rb