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

#each_message(*args) ⇒ Object 



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

def each_message(**args)
  super do |message|
    each_message_with_new_relic(message) do
      yield(message)
    end
  end
end