Sha256: 9de0d071af667a1f20cfcd47f74f148d955639d20aa4782d83e01ffbeda0f3d6

Contents?: true

Size: 502 Bytes

Versions: 160

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(:include, Appsignal::Integrations::QuePlugin)

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

Version data entries

160 entries across 160 versions & 1 rubygems

Version Path
appsignal-2.9.14-java lib/appsignal/hooks/que.rb
appsignal-2.9.14 lib/appsignal/hooks/que.rb
appsignal-2.9.13-java lib/appsignal/hooks/que.rb
appsignal-2.9.13 lib/appsignal/hooks/que.rb
appsignal-2.9.12-java lib/appsignal/hooks/que.rb
appsignal-2.9.12 lib/appsignal/hooks/que.rb
appsignal-2.9.12.beta.0-java lib/appsignal/hooks/que.rb
appsignal-2.9.12.beta.0 lib/appsignal/hooks/que.rb
appsignal-2.9.11 lib/appsignal/hooks/que.rb
appsignal-2.9.11-java lib/appsignal/hooks/que.rb
appsignal-2.9.10 lib/appsignal/hooks/que.rb
appsignal-2.9.10-java lib/appsignal/hooks/que.rb
appsignal-2.9.9-java lib/appsignal/hooks/que.rb
appsignal-2.9.9 lib/appsignal/hooks/que.rb
appsignal-2.9.8-java lib/appsignal/hooks/que.rb
appsignal-2.9.8 lib/appsignal/hooks/que.rb
appsignal-2.9.7-java lib/appsignal/hooks/que.rb
appsignal-2.9.7 lib/appsignal/hooks/que.rb
appsignal-2.9.6-java lib/appsignal/hooks/que.rb
appsignal-2.9.6 lib/appsignal/hooks/que.rb