Sha256: 8f7c87697e58070635a6e6e05f669e4d6d9dae2fc5a5114017a277013f81c0b8

Contents?: true

Size: 714 Bytes

Versions: 8

Compression:

Stored size: 714 Bytes

Contents

begin
  require 'sidekiq'
rescue LoadError
end

if defined? Sidekiq
  module Opbeat
    module Integrations
      class Sidekiq
        def call(worker, msg, queue)
          begin
            yield
          rescue Exception => ex
            raise ex if [Interrupt, SystemExit, SignalException].include? ex.class
            ::Opbeat.capture_exception(ex)
            raise
          end
        end
      end
    end
  end

  ::Sidekiq.configure_server do |config|
    if ::Sidekiq::VERSION < '3'
      config.server_middleware do |chain|
        chain.add ::Opbeat::Integrations::Sidekiq
      end
    else
      config.error_handlers << Proc.new { |ex, ctx| ::Opbeat.capture_exception(ex) }
    end
  end
end

Version data entries

8 entries across 8 versions & 2 rubygems

Version Path
kuende-opbeat-2.0.4 lib/opbeat/integrations/sidekiq.rb
kuende-opbeat-2.0.3 lib/opbeat/integrations/sidekiq.rb
kuende-opbeat-2.0.2 lib/opbeat/integrations/sidekiq.rb
kuende-opbeat-2.0.1 lib/opbeat/integrations/sidekiq.rb
opbeat-2.0.0 lib/opbeat/integrations/sidekiq.rb
opbeat-1.1.1 lib/opbeat/integrations/sidekiq.rb
opbeat-1.1.0 lib/opbeat/integrations/sidekiq.rb
opbeat-1.0.0 lib/opbeat/integrations/sidekiq.rb