Module: NewRelic::Agent::Instrumentation::RubyKafkaProducer::Prepend

Includes:
NewRelic::Agent::Instrumentation::RubyKafka
Defined in:
lib/new_relic/agent/instrumentation/ruby_kafka/prepend.rb

Constant Summary

Constants included from NewRelic::Agent::Instrumentation::RubyKafka

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

Instance Method Summary collapse

Methods included from NewRelic::Agent::Instrumentation::RubyKafka

#create_kafka_metrics, #each_message_with_new_relic, #produce_with_new_relic

Instance Method Details

#produce(value, **kwargs) ⇒ Object 



10
11
12
13
14
15
 
# File 'lib/new_relic/agent/instrumentation/ruby_kafka/prepend.rb', line 10

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