Обновление полей каждые 5 секунд

int fixedSuccessRecords = 0;
        int fixedErrorRecords = 0;
        String fileStr;
        ObjectNode jsonNode = objectMapper.createObjectNode();
        try {
            BufferedReader bufferedReader = new BufferedReader( new FileReader(absolutePath));
            for (int i = 0; i < sourceFixed.getSkipHeaderLines(); i++) {
                fileStr = bufferedReader.readLine();
            }
            while ((fileStr = bufferedReader.readLine()) != null) {
                    for(int i = 0 ; i < sourceFixed.getMapping().size(); i++) {
                        jsonNode.put("batchId",toBatch.getId());
                        jsonNode.put("sourceId",toBatch.getSourceId().getId());
                        ToMappingFixed mappingField = sourceFixed.getMapping().get(i);
                        int sourceFixedPosition = mappingField.getFromPosition();
                        int sourceFixedLength = sourceFixedPosition + mappingField.getLength();
                        String destinationField = mappingField.getDestFieldName();
                        String linesField = fileStr.substring(sourceFixedPosition, sourceFixedLength).trim();
                        jsonNode.put(destinationField,linesField);
                    }
                fixedSuccessRecords++;
             try {
                 Object body = objectMapper.treeToValue(jsonNode, pojoClass);
                 mongoTemplate.save(body);
                 if(fixedSuccessRecords == ???) {
                     toBatch.setNoSuccess(fixedSuccessRecords);
                     toBatch.update();
                 }