class ElasticAPM::Transport::Connection

def write(str)
  connect_unless_connected
  @mutex.synchronize { append(str) }
  return unless @bytes_sent >= @config.api_request_size
  flush
rescue FailedToConnectError => e
  error "Couldn't establish connection to APM Server:\n%p", e
  flush
  nil
end