Sha256: bc9bf5a6372a497b8f489c2db611cb69a34d81868259a8c88315c0e4b0b0cd33
Contents?: true
Size: 856 Bytes
Versions: 45
Compression:
Stored size: 856 Bytes
Contents
# (c) Copyright IBM Corp. 2021
# (c) Copyright Instana Inc. 2021
module Instana
module Activators
class ResqueWorker < Activator
def can_instrument?
defined?(::Resque::Worker) &&
defined?(::Resque::Job) &&
::Instana.config[:'resque-worker'][:enabled]
end
def instrument
require 'instana/instrumentation/resque'
::Resque::Worker.prepend(::Instana::Instrumentation::ResqueWorker)
::Resque::Job.prepend(::Instana::Instrumentation::ResqueJob)
if ::Instana.config[:'resque-worker'][:'setup-fork']
::Resque.after_fork do |_job|
::Instana.agent.after_fork
end
end
# Set this so we assure that any remaining collected traces are reported at_exit
ENV['RUN_AT_EXIT_HOOKS'] = "1"
true
end
end
end
end
Version data entries
45 entries across 45 versions & 1 rubygems