git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube...

diff --git a/server/user.jobengine.executors/src/user/jobengine/server/steps/ForkUploadStep.java b/server/user.jobengine.executors/src/user/jobengine/server/steps/ForkUploadStep.java
index 92eff37abd0ee49dbcfb0f97630701fbe6bd4349..eca4024ac202580aaf12a3ce0ae387203b12a4c7 100644 (file)
--- a/server/user.jobengine.executors/src/user/jobengine/server/steps/ForkUploadStep.java
+++ b/server/user.jobengine.executors/src/user/jobengine/server/steps/ForkUploadStep.java
@@ -33,7 +33,8 @@ public class ForkUploadStep extends JobStep {
        private static final Logger logger = LogManager.getLogger();\r
 \r
        @StepEntry\r
-       public Object[] execute(String tempStoreName, String template, String expectedColorSpace, int limit) throws Exception {\r
+       public Object[] execute(String tempStoreName, String template, String expectedColorSpace, int limit)\r
+                       throws Exception {\r
                DirectoryStream<Path> directoryStream = null;\r
                int count = limit;\r
                int allCount = 0;\r
@@ -63,12 +64,12 @@ public class ForkUploadStep extends JobStep {
                                escortFiles.add(escortFile);\r
                        }\r
                        allCount = escortFiles.size();\r
-                       //a file neve az adasbakerules idopontjaval kezdodik\r
-                       //                      escortFiles.sort((p1, p2) -> {\r
-                       //                              return p1.compareTo(p2);\r
-                       //                      });\r
+                       // a file neve az adasbakerules idopontjaval kezdodik\r
+                       // escortFiles.sort((p1, p2) -> {\r
+                       // return p1.compareTo(p2);\r
+                       // });\r
 \r
-                       //200911 megis inkabb a letrehozas idopontja legyen\r
+                       // 200911 megis inkabb a letrehozas idopontja legyen\r
                        try {\r
                                escortFiles.sort((p1, p2) -> {\r
                                        int result = 0;\r
@@ -138,20 +139,20 @@ public class ForkUploadStep extends JobStep {
                if (escortFile.toFile().isDirectory())\r
                        return false;\r
 \r
-               //ami nem JSON azt nem kezeljuk\r
+               // ami nem JSON azt nem kezeljuk\r
                if (!escortFile.getFileName().toString().toLowerCase().endsWith(EscortFiles.DOT_JSON))\r
                        return false;\r
 \r
-               //aminek van COLORSPACE kiterjesztésű\r
-               //              Path colorspaceFile = Paths.get(escortFile.toString() + ".colorspace");\r
-               //              if (colorspaceFile.toFile().exists())\r
-               //                      return false;\r
+               // aminek van COLORSPACE kiterjesztésű\r
+               // Path colorspaceFile = Paths.get(escortFile.toString() + ".colorspace");\r
+               // if (colorspaceFile.toFile().exists())\r
+               // return false;\r
 \r
                if (EscortFiles.isCatchedFileExists(escortFile))\r
                        return false;\r
 \r
                String escortFileName = escortFile.getFileName().toString();\r
-               //minimum 3 karakter: STORENAME.FILENAME.MXF.JSON\r
+               // minimum 3 karakter: STORENAME.FILENAME.MXF.JSON\r
                long dotCount = escortFileName.chars().filter(ch -> ch == '.').count();\r
                if (dotCount < 3)\r
                        return false;\r
@@ -193,11 +194,12 @@ public class ForkUploadStep extends JobStep {
                        parameters.put("expectedColorSpace", downloadable.getString("colorSpace"));\r
                        parameters.put("escortFile", escortFile.toAbsolutePath().toString());\r
 \r
-                       //int priority = downloadable.containsKey("priority") ? downloadable.getInt("priority") : 0;\r
-                       //mindenki egyforman induljon 20.09.07\r
-                       //a NEXIO egy kicsit fontosabb 20.09.08. megsem 20.09.09\r
-                       //int priority = escortFile.toString().contains("NEXIO") ? 51 : 50;\r
-                       //megszakitasok miatt a mar lejott mozikat vegyuk elore 20.09.09\r
+                       // int priority = downloadable.containsKey("priority") ?\r
+                       // downloadable.getInt("priority") : 0;\r
+                       // mindenki egyforman induljon 20.09.07\r
+                       // a NEXIO egy kicsit fontosabb 20.09.08. megsem 20.09.09\r
+                       // int priority = escortFile.toString().contains("NEXIO") ? 51 : 50;\r
+                       // megszakitasok miatt a mar lejott mozikat vegyuk elore 20.09.09\r
 \r
                        int priority = 50;\r
                        if (targetExists(tempStoreUri, targetFileName))\r