private void processThesaurus(final Stream<ThesaurusEntry> entries, final int totalEntries,
            final Consumer<ThesaurusEntry> dataProcessor){
        try{
            final Consumer<ThesaurusEntry> innerProcessor = createInnerProcessor(dataProcessor, totalEntries);
            entries.forEach(innerProcessor);