class ApmServerLogShipper extends AbstractIntakeApiHandler implements FileChangeListener {

    private void write(OutputStream os, byte[] line, int offset, int length, boolean eol) throws IOException {
        os.write(line, offset, length);
        if (eol) {
            currentlyTransmitting++;
            os.write('\n');
            if (shouldEndRequest()) {
                endRequest();
            }
        }
    }

    public  ApmServerLogShipper(ApmServerClient apmServerClient, ReporterConfiguration reporterConfiguration, MetaData metaData, PayloadSerializer payloadSerializer);

}