class ElasticAPM::Transport::Base

def stop_workers
  return unless @pool.running?
  debug 'Stopping workers'
  send_stop_messages
  debug 'Shutting down pool'
  @pool.shutdown
  return if @pool.wait_for_termination(5)
  warn "Worker pool didn't close in 5 secs, killing ..."
  @pool.kill
end