MD5 számításhoz fájlok létrehozása

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

diff --git a/server/-product/production/MEDIAVIVANTIS/jobs/executors.xml b/server/-product/production/MEDIAVIVANTIS/jobs/executors.xml
index a0541aaea84f8a4764fa3836000122dc5dd8fe8b..d0a69954f301bdb8960b508217403dc67df54f9c 100644 (file)
--- a/server/-product/production/MEDIAVIVANTIS/jobs/executors.xml
+++ b/server/-product/production/MEDIAVIVANTIS/jobs/executors.xml
@@ -22,6 +22,7 @@
        <executor className="CreateMissingLowresStep.java" maxConcurrent="1" isRemote="false" />\r
        <executor className="FileCopyStep.java" maxConcurrent="20" isRemote="false" />\r
        <executor className="HSMMigrateStep.java" maxConcurrent="1" isRemote="false" />\r
+       <executor className="CalculateMD5Step.java" maxConcurrent="1" isRemote="false "/>\r
        <executor className="MediaToolStep.java" maxConcurrent="1" isRemote="false" />\r
        <executor className="MetadataTransformStep.java" maxConcurrent="1" isRemote="false" />\r
        <executor className="MXFCutterStep.java" maxConcurrent="1" isRemote="false" />\r

diff --git a/server/-product/production/MEDIAVIVANTIS/jobs/steps/CalculateMD5Step.java b/server/-product/production/MEDIAVIVANTIS/jobs/steps/CalculateMD5Step.java
new file mode 100644 (file)
index 0000000..6cb3374
--- /dev/null
+++ b/server/-product/production/MEDIAVIVANTIS/jobs/steps/CalculateMD5Step.java
@@ -0,0 +1,31 @@
+package user.jobengine.server.steps;\r
+\r
+import org.apache.logging.log4j.LogManager;\r
+import org.apache.logging.log4j.Logger;\r
+import org.apache.logging.log4j.message.Message;\r
+import org.apache.logging.log4j.message.ParameterizedMessage;\r
+\r
+import user.commons.MediaCubeMarker;\r
+\r
+public class CalculateMD5Step extends JobStep {\r
+       private static final Logger logger = LogManager.getLogger();\r
+\r
+       @StepEntry\r
+       public Object[] execute(int param) throws Exception {\r
+               logger.info(getMarker(), "Executing");\r
+               Message msg = new ParameterizedMessage("");\r
+               logger.info(new MediaCubeMarker("vasary@elgekko.net,vasary@gmail.com", "MediaCube rendszerüzenet"), msg);\r
+\r
+               for (int i = 0; i < 10; i++) {\r
+                       logger.info(getMarker(), "Executing {}", i);\r
+                       if (getJobRuntime().isWaitingCancel())\r
+                               break;\r
+                       Thread.sleep(100);\r
+                       int progress = (i + 1) * 100 / 10;\r
+                       setProgress(progress);\r
+               }\r
+\r
+               return null;\r
+       }\r
+\r
+}\r

diff --git a/server/-product/production/MEDIAVIVANTIS/jobs/templates/calculatemd5.xml b/server/-product/production/MEDIAVIVANTIS/jobs/templates/calculatemd5.xml
new file mode 100644 (file)
index 0000000..3c8426d
--- /dev/null
+++ b/server/-product/production/MEDIAVIVANTIS/jobs/templates/calculatemd5.xml
@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>\r
+<jobtemplate multiInstance="true" useSessionLog="false">\r
+       <declarations>\r
+               <parameters>\r
+                       <parameter name="param" type="java.lang.Integer" />\r
+               </parameters>\r
+       </declarations>\r
+       <commands>\r
+               <calljobstep remote="true" type="CalculateMD5Step.java" weight="1" >\r
+                       <inputs>\r
+                               <input>\r
+                                       <parameter name="param" />\r
+                               </input>\r
+                       </inputs>\r
+               </calljobstep>\r
+       </commands>\r
+</jobtemplate>
\ No newline at end of file

diff --git a/server/user.jobengine.executors/src/user/jobengine/server/steps/CalculateMD5Step.java b/server/user.jobengine.executors/src/user/jobengine/server/steps/CalculateMD5Step.java
new file mode 100644 (file)
index 0000000..8dbdc1d
--- /dev/null
+++ b/server/user.jobengine.executors/src/user/jobengine/server/steps/CalculateMD5Step.java
@@ -0,0 +1,22 @@
+package user.jobengine.server.steps;\r
+\r
+import org.apache.logging.log4j.LogManager;\r
+import org.apache.logging.log4j.Logger;\r
+\r
+public class CalculateMD5Step extends JobStep {\r
+       private static final Logger logger = LogManager.getLogger();\r
+\r
+       @StepEntry\r
+       public Object[] execute(int param) throws Exception {\r
+               logger.info(getMarker(), "Executing with param {}", param);\r
+               for (int i = 0; i < 10; i++) {\r
+                       if (getJobRuntime().isWaitingCancel())\r
+                               break;\r
+                       Thread.sleep(10);\r
+                       int progress = (i + 1) * 100 / 10;\r
+                       setProgress(progress);\r
+               }\r
+               return null;\r
+       }\r
+\r
+}\r