Sha256: e609d0cfb01ec97281dbfb4333baec960f14ac52669f5fa761f1cfe6880b6d68
Contents?: true
Size: 1.07 KB
Versions: 5
Compression:
Stored size: 1.07 KB
Contents
# encoding: utf-8
# This file is distributed under New Relic's license terms.
# See https://github.com/newrelic/newrelic-ruby-agent/blob/main/LICENSE for complete details.
# frozen_string_literal: true
module NewRelic::Agent::Instrumentation
module Resque
include NewRelic::Agent::Instrumentation::ControllerInstrumentation
def with_tracing
begin
perform_action_with_newrelic_trace(
:name => 'perform',
:class_name => self.payload_class,
:category => 'OtherTransaction/ResqueJob') do
NewRelic::Agent::Transaction.merge_untrusted_agent_attributes(
args,
:'job.resque.args',
NewRelic::Agent::AttributeFilter::DST_NONE)
yield
end
ensure
# Stopping the event loop before flushing the pipe.
# The goal is to avoid conflict during write.
if NewRelic::Agent::Instrumentation::Resque::Helper.resque_fork_per_job?
NewRelic::Agent.agent.stop_event_loop
NewRelic::Agent.agent.flush_pipe_data
end
end
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems