@Override
    public void startProcessing() {
        try {
            recordCount.setStartMs(System.currentTimeMillis());
            if (countRead) {
                incrementor = () -> {
                    recordCount.getReadIncrementor().increment();
                    recordCountService.getReadIncrementor().increment();
                };
            } else {
                incrementor = () -> {
                    recordCount.getWriteIncrementor().increment();
                    recordCountService.getWriteIncrementor().increment();
                };
            }
        } finally {
            super.startProcessing();
        }
    }
@see stroom.pipeline.filter.AbstractXMLFilter#startProcessing()
stroom-pipeline/src/main/java/stroom/pipeline/filter/RecordCountFilter.java