Contents

module Appsignal
  class Hooks
    class DelayedJobPlugin < ::Delayed::Plugin
      callbacks do |lifecycle|
        lifecycle.around(:invoke_job) do |job, &block|
          invoke_with_instrumentation(job, block)
        end

        lifecycle.after(:loop) do |loop|
          Appsignal.stop
        end
      end

      def self.invoke_with_instrumentation(job, block)
        class_and_method_name = if job.payload_object.respond_to?(:appsignal_name)
                                  job.payload_object.appsignal_name
                                else
                                  job.name
                                end
        class_name, method_name = class_and_method_name.split('#')

        Appsignal.monitor_transaction(
          'perform_job.delayed_job',
          :class    => class_name,
          :method   => method_name,
          :metadata => {
            :id       => job.id,
            :queue    => job.queue,
            :priority => job.priority || 0,
            :attempts => job.attempts || 0
          },
          :queue_start => job.created_at
        ) do
          block.call(job)
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
appsignal-1.0.0.rc.1	lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-0.12.rc.14	lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-0.12.rc.9	lib/appsignal/integrations/delayed_job_plugin.rb
appsignal-0.12.rc.8	lib/appsignal/integrations/delayed_job_plugin.rb