class ElasticAPM::Spies::RacecarSpy::ConsumerSubscriber

@api private

def process_batch(_event) 

def process_batch(_event)
  ElasticAPM.end_transaction
end

def process_message(_event) 

def process_message(_event)
  ElasticAPM.end_transaction
end

def start_process_batch(event) 

def start_process_batch(event)
  start_process_transaction(event: event, kind: 'process_batch')
end

def start_process_message(event) 

def start_process_message(event)
  start_process_transaction(event: event, kind: 'process_message')
end

def start_process_transaction(event:, kind:) 

def start_process_transaction(event:, kind:)
  ElasticAPM.start_transaction(kind, TYPE)
  ElasticAPM.current_transaction.context.set_service(framework_name: 'racecar', framework_version: Racecar::VERSION)
end