class ElasticAPM::Spies::RacecarSpy::ProducerSubscriber

def deliver_message(_event)
  ElasticAPM.end_transaction
end

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