class ElasticAPM::Spies::RacecarSpy::ConsumerSubscriber

@api private

Public Instance Methods

process_batch(_event) click to toggle source
# File lib/elastic_apm/spies/racecar.rb, line 43
def process_batch(_event)
  ElasticAPM.end_transaction
end
process_message(_event) click to toggle source
# File lib/elastic_apm/spies/racecar.rb, line 36
def process_message(_event)
  ElasticAPM.end_transaction
end
start_process_batch(event) click to toggle source
# File lib/elastic_apm/spies/racecar.rb, line 40
def start_process_batch(event)
  start_process_transaction(event: event, kind: 'process_batch')
end
start_process_message(event) click to toggle source
# File lib/elastic_apm/spies/racecar.rb, line 33
def start_process_message(event)
  start_process_transaction(event: event, kind: 'process_message')
end