class ElasticAPM::Agent

def kill_worker
  messages << TimedWorker::StopMsg.new
  if @worker_thread && !@worker_thread.join(5) # 5 secs
    raise 'Failed to wait for worker, not all messages sent'
  end
  @worker_thread = nil
end