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.1.2-java lib/appsignal/hooks/que.rb
appsignal-3.1.2 lib/appsignal/hooks/que.rb
appsignal-3.1.1-java lib/appsignal/hooks/que.rb
appsignal-3.1.1 lib/appsignal/hooks/que.rb
appsignal-3.1.0-java lib/appsignal/hooks/que.rb
appsignal-3.1.0 lib/appsignal/hooks/que.rb
appsignal-3.0.27-java lib/appsignal/hooks/que.rb
appsignal-3.0.27 lib/appsignal/hooks/que.rb
appsignal-3.0.26-java lib/appsignal/hooks/que.rb
appsignal-3.0.26 lib/appsignal/hooks/que.rb
appsignal-3.0.25-java lib/appsignal/hooks/que.rb
appsignal-3.0.25 lib/appsignal/hooks/que.rb
appsignal-3.0.24-java lib/appsignal/hooks/que.rb
appsignal-3.0.24 lib/appsignal/hooks/que.rb
appsignal-3.0.23-java lib/appsignal/hooks/que.rb
appsignal-3.0.23 lib/appsignal/hooks/que.rb
appsignal-3.0.22-java lib/appsignal/hooks/que.rb
appsignal-3.0.22 lib/appsignal/hooks/que.rb
appsignal-3.0.21-java lib/appsignal/hooks/que.rb
appsignal-3.0.21 lib/appsignal/hooks/que.rb