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.11.10-java lib/appsignal/hooks/que.rb
appsignal-2.11.10 lib/appsignal/hooks/que.rb
appsignal-2.11.9-java lib/appsignal/hooks/que.rb
appsignal-2.11.9 lib/appsignal/hooks/que.rb
appsignal-2.11.8-java lib/appsignal/hooks/que.rb
appsignal-2.11.8 lib/appsignal/hooks/que.rb
appsignal-2.11.7 lib/appsignal/hooks/que.rb
appsignal-2.11.7-java lib/appsignal/hooks/que.rb
appsignal-2.11.6 lib/appsignal/hooks/que.rb
appsignal-2.11.6-java lib/appsignal/hooks/que.rb
appsignal-2.11.5-java lib/appsignal/hooks/que.rb
appsignal-2.11.5 lib/appsignal/hooks/que.rb
appsignal-2.11.4-java lib/appsignal/hooks/que.rb
appsignal-2.11.4 lib/appsignal/hooks/que.rb
appsignal-2.11.3-java lib/appsignal/hooks/que.rb
appsignal-2.11.3 lib/appsignal/hooks/que.rb
appsignal-2.11.2-java lib/appsignal/hooks/que.rb
appsignal-2.11.2 lib/appsignal/hooks/que.rb
appsignal-2.11.1-java lib/appsignal/hooks/que.rb
appsignal-2.11.1 lib/appsignal/hooks/que.rb