Sha256: 952256608d3c07bda1ee2b9ba1039bdf22884920f8bbe9eea3c364a9c084c665
Contents?: true
Size: 933 Bytes
Versions: 19
Compression:
Stored size: 933 Bytes
Contents
if defined?(::Delayed::Plugin)
Appsignal.logger.info('Loading Delayed Job integration')
module Appsignal
module Integrations
class DelayedPlugin < ::Delayed::Plugin
callbacks do |lifecycle|
lifecycle.around(:invoke_job) do |job, &block|
invoke_with_instrumentation(job, block)
end
end
def self.invoke_with_instrumentation(job, block)
class_name, method_name = job.name.split('#')
Appsignal.monitor_transaction(
'perform_job.delayed_job',
:class => class_name,
:method => method_name,
:priority => job.priority,
:attempts => job.attempts,
:queue => job.queue,
:queue_start => job.created_at
) do
block.call(job)
end
end
end
end
end
::Delayed::Worker.plugins << Appsignal::Integrations::DelayedPlugin
end
Version data entries
19 entries across 19 versions & 1 rubygems