private Consumer<CorrectionEntry> createInnerProcessor(final Consumer<CorrectionEntry> dataProcessor, final int totalEntries){
        final AtomicInteger processingIndex = new AtomicInteger(0);
        return data -> {
            try{
                dataProcessor.accept(data);