Method: Kafka::Instrumenter#initialize

Defined in:
lib/kafka/instrumenter.rb

#initialize(default_payload = {}) ⇒ Instrumenter

Returns a new instance of Instrumenter.



7
8
9
10
11
12
13
14
15
 
# File 'lib/kafka/instrumenter.rb', line 7

def initialize(default_payload = {})
  @default_payload = default_payload

  if defined?(ActiveSupport::Notifications)
    @backend = ActiveSupport::Notifications
  else
    @backend = nil
  end
end