git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube...
authorSweidan Omar <TFS\sweidan.omar>
Mon, 2 May 2022 10:01:28 +0000 (10:01 +0000)
committerSweidan Omar <TFS\sweidan.omar>
Mon, 2 May 2022 10:01:28 +0000 (10:01 +0000)
server/user.jobengine.executors/src/user/jobengine/server/steps/FileValidatorStep.java

index fec2a359857751b1c6ae6ed38d94798f1b76b650..62fa66ea50dcb146e8b08c9d7a903aae14aea044 100644 (file)
@@ -28,7 +28,7 @@ public class FileValidatorStep extends JobStep {
                        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
@@ -36,7 +36,7 @@ public class FileValidatorStep extends JobStep {
 \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
@@ -70,14 +70,13 @@ public class FileValidatorStep extends JobStep {
                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