Module: NewRelic::Agent::Instrumentation::RdkafkaProducer::Prepend

Includes:
NewRelic::Agent::Instrumentation::Rdkafka
Defined in:
lib/new_relic/agent/instrumentation/rdkafka/prepend.rb

Constant Summary

Constants included from NewRelic::Agent::Instrumentation::Rdkafka

NewRelic::Agent::Instrumentation::Rdkafka::CONSUME, NewRelic::Agent::Instrumentation::Rdkafka::INSTRUMENTATION_NAME, NewRelic::Agent::Instrumentation::Rdkafka::MESSAGING_LIBRARY, NewRelic::Agent::Instrumentation::Rdkafka::PRODUCE

Instance Method Summary collapse

Methods included from NewRelic::Agent::Instrumentation::Rdkafka

#create_kafka_metrics, #each_with_new_relic, #produce_with_new_relic

Instance Method Details

#produce(**kwargs) ⇒ Object 



12
13
14
15
16
17
 
# File 'lib/new_relic/agent/instrumentation/rdkafka/prepend.rb', line 12

def produce(**kwargs)
  produce_with_new_relic(kwargs) do |headers|
    kwargs[:headers] = headers
    super
  end
end