Sha256: d1908a87880f41808c06b7e62a973a1a4a20497654929ee3965b6a39c5f9be75

Contents?: true

Size: 502 Bytes

Versions: 110

Compression:

Stored size: 502 Bytes

Contents

# frozen_string_literal: true

module Appsignal
  class Hooks
    # @api private
    class QueHook < Appsignal::Hooks::Hook
      register :que

      def dependencies_present?
        defined?(::Que::Job)
      end

      def install
        require "appsignal/integrations/que"
        ::Que::Job.send(:prepend, Appsignal::Integrations::QuePlugin)

        ::Que.error_notifier = proc do |error, _job|
          Appsignal::Transaction.current.set_error(error)
        end
      end
    end
  end
end

Version data entries

110 entries across 110 versions & 1 rubygems

Version Path
appsignal-3.0.21.alpha.1-java lib/appsignal/hooks/que.rb
appsignal-3.0.21.alpha.1 lib/appsignal/hooks/que.rb
appsignal-3.0.20-java lib/appsignal/hooks/que.rb
appsignal-3.0.20 lib/appsignal/hooks/que.rb
appsignal-3.0.19-java lib/appsignal/hooks/que.rb
appsignal-3.0.19 lib/appsignal/hooks/que.rb
appsignal-3.0.18-java lib/appsignal/hooks/que.rb
appsignal-3.0.18 lib/appsignal/hooks/que.rb
appsignal-3.0.17-java lib/appsignal/hooks/que.rb
appsignal-3.0.17 lib/appsignal/hooks/que.rb
appsignal-3.0.16-java lib/appsignal/hooks/que.rb
appsignal-3.0.16 lib/appsignal/hooks/que.rb
appsignal-3.0.15-java lib/appsignal/hooks/que.rb
appsignal-3.0.15 lib/appsignal/hooks/que.rb
appsignal-3.0.14-java lib/appsignal/hooks/que.rb
appsignal-3.0.14 lib/appsignal/hooks/que.rb
appsignal-3.0.13-java lib/appsignal/hooks/que.rb
appsignal-3.0.13 lib/appsignal/hooks/que.rb
appsignal-3.0.12-java lib/appsignal/hooks/que.rb
appsignal-3.0.12 lib/appsignal/hooks/que.rb