Sha256: 65c1b9a4c72e61186f4fefb892c592778407f206775ea3af43ba00b15cac8b1e
Contents?: true
Size: 1.09 KB
Versions: 9
Compression:
Stored size: 1.09 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
9 entries across 9 versions & 1 rubygems