throw new Exception("Store URI protocol must be local.");\r
Path filePath = Paths.get(sourceStoreUri.toString(true), fileName);\r
if (!filePath.toFile().exists())\r
- throw new FileNotFoundException("File not exists: " + filePath.toString());\r
+ throw new FileNotFoundException("File does not exist: " + filePath.toString());\r
\r
setDescription("Validating {}", fileName);\r
\r
\r
if (getJobRuntime().isWaitingCancel()) {\r
EscortFiles.remove(filePath);\r
- //EscortFiles.remove(escortFilePath);\r
+ // EscortFiles.remove(escortFilePath);\r
EscortFiles.remove(Paths.get(escortFile + EscortFiles.DOT_CATCHED));\r
\r
Message msg = new ParameterizedMessage("A {} fájl visszatöltése kezelői beavatkozás miatt megszakadt.",\r
if (expectedSize > 0)\r
validateSize(filePath, expectedSize, escortFile);\r
\r
- //A metadata persister miatt torlunk mindet teszt modban\r
+ // A metadata persister miatt torlunk mindet teszt modban\r
/*\r
- if (StringUtils.isNotBlank(testSimulate)) {\r
- EscortFiles.remove(escortFilePath);\r
- EscortFiles.remove(Paths.get(escortFile + EscortFiles.DOT_CATCHED));\r
- logger.info(getMarker(), "{} deleted to prevent real processing", escortFile);\r
- }\r
- */\r
+ * if (StringUtils.isNotBlank(testSimulate)) {\r
+ * EscortFiles.remove(escortFilePath); EscortFiles.remove(Paths.get(escortFile +\r
+ * EscortFiles.DOT_CATCHED)); logger.info(getMarker(),\r
+ * "{} deleted to prevent real processing", escortFile); }\r
+ */\r
logger.info(getMarker(), "{} passed validation", fileName);\r
return null;\r
}\r