Module: NewRelic::Agent::Instrumentation::RdkafkaConsumer::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

#each ⇒ Object 



25
26
27
28
29
30
31
 
# File 'lib/new_relic/agent/instrumentation/rdkafka/prepend.rb', line 25

def each
  super do |message|
    each_with_new_relic(message) do
      yield(message)
    end
  end
end