--- /dev/null
+<?xml version="1.0" encoding="UTF-8" standalone="no"?>\r
+<launchConfiguration type="org.eclipse.m2e.Maven2LaunchConfigurationType">\r
+<booleanAttribute key="M2_DEBUG_OUTPUT" value="false"/>\r
+<stringAttribute key="M2_GOALS" value="clean install"/>\r
+<booleanAttribute key="M2_NON_RECURSIVE" value="false"/>\r
+<booleanAttribute key="M2_OFFLINE" value="false"/>\r
+<stringAttribute key="M2_PROFILES" value=""/>\r
+<listAttribute key="M2_PROPERTIES"/>\r
+<stringAttribute key="M2_RUNTIME" value="EMBEDDED"/>\r
+<booleanAttribute key="M2_SKIP_TESTS" value="false"/>\r
+<intAttribute key="M2_THREADS" value="1"/>\r
+<booleanAttribute key="M2_UPDATE_SNAPSHOTS" value="false"/>\r
+<stringAttribute key="M2_USER_SETTINGS" value=""/>\r
+<booleanAttribute key="M2_WORKSPACE_RESOLUTION" value="false"/>\r
+<listAttribute key="org.eclipse.debug.ui.favoriteGroups">\r
+<listEntry value="org.eclipse.debug.ui.launchGroup.run"/>\r
+</listAttribute>\r
+<stringAttribute key="org.eclipse.jdt.launching.WORKING_DIRECTORY" value="${workspace_loc}/-modules"/>\r
+</launchConfiguration>\r
<?xml version="1.0" encoding="UTF-8"?>\r
<classpath>\r
- <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8"/>\r
<classpathentry kind="con" path="org.eclipse.pde.core.requiredPlugins"/>\r
<classpathentry kind="src" path="src"/>\r
+ <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>\r
<classpathentry kind="output" path="bin"/>\r
</classpath>\r
<classpath>\r
<classpathentry kind="src" path="src"/>\r
<classpathentry kind="con" path="org.eclipse.pde.core.requiredPlugins"/>\r
- <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8"/>\r
+ <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>\r
<classpathentry kind="output" path="bin"/>\r
</classpath>\r
<?xml version="1.0" encoding="UTF-8"?>\r
<executors>\r
- <executor className="user.jobengine.server.steps.FakeStep" maxConcurrent="2"/>\r
+ <executor className="user.jobengine.server.steps.FakeStep" maxConcurrent="20"/>\r
+ <executor className="user.jobengine.server.steps.FakeNoParamsStep" maxConcurrent="20"/>\r
<executor className="user.jobengine.server.steps.ArchiveMaterialSubmitStep" maxConcurrent="1"/>\r
<executor className="user.jobengine.server.steps.ArchiveListBuilderStep" maxConcurrent="1"/>\r
<executor className="user.jobengine.server.steps.CheckTRAFFICMissingMaterialsStep" maxConcurrent="1"/>\r
]\r
},\r
{\r
- "active": true,\r
+ "active": false,\r
"executeimmediate": false,\r
"name" : "Lejárt ISISLON/ARCHIVE anyagok törlése",\r
"template": "delete-materials.xml",\r
]\r
}, \r
{\r
- "active": false,\r
- "executeimmediate": true,\r
+ "active": true,\r
+ "executeimmediate": false,\r
"name" : "NEXIO anyagok másolása az ISILON/ARCHIVE mappába",\r
"template": "copyforarchive-nexio-materials.xml",\r
- "cronexpression": "0 0 0/1 1/1 * ? *",\r
+ "cronexpression": "0 0 10 * * ?",\r
"parameters": [ \r
{"name": "nexioPort", "value": 2098, "type": "java.lang.Integer"},\r
{"name": "nexioUserName", "value": "administrator", "type": "java.lang.String"},\r
{"name": "nexioPassword", "value": "system", "type": "java.lang.String"},\r
- {"name": "archiveFtp", "value": "ftp://10.10.1.100/ARCHIVE/TEST", "type": "java.lang.String"},\r
+ {"name": "archiveFtp", "value": "ftp://10.10.1.100/ARCHIVE", "type": "java.lang.String"},\r
{"name": "archiveUserName", "value": "mediacube", "type": "java.lang.String"},\r
{"name": "archivePassword", "value": "Broadca5T", "type": "java.lang.String"},\r
{"name": "daysBeforeNow", "value": 1, "type": "java.lang.Integer"},\r
}, \r
{\r
"active": false,\r
- "executeimmediate": true,\r
- "name" : "Archiválás az ISILON/ARCHIVE/ONE mappából",\r
- "template": "archive-ondemand.xml",\r
- "cronexpression": "0 0 0/1 1/1 * ? *",\r
- "parameters": [ \r
- {"name": "sourcePath", "value": "/mnt/ISILON/ARCHIVE/ONE", "type": "java.lang.String"},\r
- {"name": "globalSourcePath", "value": "\\\\10.10.1.100\\BRAAVOS\\ARCHIVE\\ONE", "type": "java.lang.String"},\r
- {"name": "transcoderTargetPath", "value": "/mnt/SELENIO", "type": "java.lang.String"},\r
- {"name": "webPath", "value": "/mediacube/data/lowres/www/video", "type": "java.lang.String"},\r
- {"name": "killDateDays", "value": 1, "type": "java.lang.Integer"}\r
- ]\r
- },\r
- {\r
- "active": false,\r
"executeimmediate": true,\r
"name" : "TRAFFIC anyagok visszatöltése",\r
"template": "retrieve-traffic-missing-materials.xml",\r
}, \r
{\r
"active": false,\r
- "executeimmediate": true,\r
+ "executeimmediate": false,\r
"name" : "NEXIO anyagok törlése",\r
"template": "delete-nexio-materials.xml",\r
"cronexpression": "0 0 0/1 1/1 * ? *",\r
int count = 10;\r
\r
@StepEntry\r
- public Object[] execute(IJobEngine jobEngine, IJobRuntime jobRuntime) {\r
- try {\r
- logger.warn("| + | FakeNoParams step");\r
- jobRuntime.incrementProgress(50);\r
- Thread.sleep(15000);\r
- jobRuntime.incrementProgress(100);\r
- logger.warn("| - | FakeNoParams step");\r
- } catch (Exception e) {\r
- logger.error(e.getMessage());\r
+ public Object[] execute(IJobEngine jobEngine, IJobRuntime jobRuntime) throws InterruptedException {\r
+ // try {\r
+ // logger.warn("| + | FakeNoParams step");\r
+ // jobRuntime.incrementProgress(50);\r
+ // Thread.sleep(15000);\r
+ // jobRuntime.incrementProgress(100);\r
+ // logger.warn("| - | FakeNoParams step");\r
+ // } catch (Exception e) {\r
+ // logger.error(e.getMessage());\r
+ // }\r
+ for (int i = 0; i < count; i++) {\r
+ if (!canContinue())\r
+ break;\r
+ jobRuntime.incrementProgress((i + 1) * count);\r
+ Thread.sleep(5000);\r
+ //logger.info(getMarker(), "Log markered");\r
+ //logger.info("Progress {}", jobRuntime.getProgress());\r
}\r
return null;\r
}\r
if (!canContinue())\r
break;\r
jobRuntime.incrementProgress((i + 1) * count);\r
- Thread.sleep(1000);\r
+ Thread.sleep(500);\r
//logger.info(getMarker(), "Log markered");\r
//logger.info("Progress {}", jobRuntime.getProgress());\r
}\r
<?xml version="1.0" encoding="UTF-8"?>\r
<classpath>\r
- <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8"/>\r
<classpathentry kind="con" path="org.eclipse.pde.core.requiredPlugins"/>\r
<classpathentry kind="src" path="src"/>\r
<classpathentry kind="src" path="test"/>\r
+ <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>\r
<classpathentry kind="output" path="bin"/>\r
</classpath>\r
<classpathentry excluding="user/jobengine/remotefiles/jcifs/smb/" kind="src" path="src"/>\r
<classpathentry kind="src" path="test"/>\r
<classpathentry kind="src" path="generated"/>\r
- <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8"/>\r
+ <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>\r
<classpathentry kind="output" path="bin"/>\r
</classpath>\r
<?xml version="1.0" encoding="UTF-8" standalone="no"?>\r
<launchConfiguration type="org.eclipse.m2e.Maven2LaunchConfigurationType">\r
<booleanAttribute key="M2_DEBUG_OUTPUT" value="false"/>\r
-<stringAttribute key="M2_GOALS" value="clean deploy -DdeploySingle"/>\r
+<stringAttribute key="M2_GOALS" value="clean install"/>\r
<booleanAttribute key="M2_NON_RECURSIVE" value="false"/>\r
<booleanAttribute key="M2_OFFLINE" value="false"/>\r
<stringAttribute key="M2_PROFILES" value=""/>\r
<custom-attributes org.zkoss.zul.listbox.preloadSize="50" />\r
\r
<div id="scdiv" width="100%" height="100%" apply="org.zkoss.bind.BindComposer" viewModel="@id('jlm') @init('user.jobengine.zk.model.JobListModel')" >\r
- <timer id="timer" delay="100" repeats="true" onTimer="@command('refreshJobList')" />\r
+ <timer id="timer" delay="500" repeats="true" onTimer="@command('refreshJobList')" />\r
\r
<space bar="false" />\r
\r
<div height="100%" width="100%" style="background: #e3e3e3" align="left">\r
<groupbox height="94%" closable="false">\r
<caption sclass="boldfont" label="Aktív folyamatok" />\r
- <listbox id="lbJobList" sizedByContent="false" model="@load(jlm.jobList)" multiple="true" autopaging="false" mold="paging" vflex="true" checkmark="true" \r
+ <listbox id="lbJobList" sizedByContent="false" model="@load(jlm.jobList)" multiple="true" pagingPosition="top" mold="paging" autopaging="false" vflex="true" checkmark="true" \r
onSelect="@command('selectJob')" style="border: none; background: #e3e3e3 !important;" oddRowSclass="listbox-odd-style" sclass="listbox-normal-style" \r
emptyMessage="Nincs futó folyamat.">\r
<listhead sizable="true">\r
<menu sclass="whitemenu" label="Archívum" >\r
<menupopup>\r
<menuitem sclass="rozsda" label="Keresés" onClick='includeContent.src="/pages/search_items.zul"' disabled="false" />\r
- <menuitem sclass="rozsda" label="Statisztikák" onClick='includeContent.src="/pages/statistics.zul"' disabled="false" />\r
- <menuitem sclass="rozsda" label="Folyamatok" onClick='includeContent.src="/pages/joblist.zul"' disabled="false" />\r
+<!-- <menuitem sclass="rozsda" label="Statisztikák" onClick='includeContent.src="/pages/statistics.zul"' disabled="false" /> -->\r
+<!-- <menuitem sclass="rozsda" label="Folyamatok" onClick='includeContent.src="/pages/joblist.zul"' disabled="false" /> -->\r
</menupopup>\r
</menu>\r
\r
}\r
}\r
\r
+ @Command\r
+ @NotifyChange({ "shutdownDisabled", "startupDisabled" })\r
+ public void restart() {\r
+ startupDisabled = true;\r
+ try {\r
+ jobEngine.startup();\r
+ } catch (Exception e) {\r
+ }\r
+ shutdownDisabled = false;\r
+ initializeList();\r
+ }\r
+\r
@Command\r
@NotifyChange({ "updatePriorityDisabled" })\r
public void selectJob() {\r
shutdownDisabled = false;\r
initializeList();\r
}\r
-\r
}\r
public void execute() {\r
if (selectedJobElement == null)\r
return;\r
- SchedulerService scheduler = jobEngine.getScheduler();\r
- ScheduledJob scheduledJob = scheduler.createScheduledJob(selectedJobElement.getDbObject());\r
- scheduledJob.setJobEngine(jobEngine);\r
- for (int i = 0; i < 1; i++) {\r
-\r
- try {\r
- if (!scheduledJob.isActive())\r
- scheduler.register(scheduledJob);\r
- scheduler.executeImmediate(scheduledJob.getJobId());\r
- Thread.sleep(100);\r
- } catch (Exception e) {\r
- Messagebox.show(e.getMessage());\r
+\r
+ Runnable r = new Runnable() {\r
+\r
+ @Override\r
+ public void run() {\r
+ SchedulerService scheduler = jobEngine.getScheduler();\r
+ ScheduledJob scheduledJob = scheduler.createScheduledJob(selectedJobElement.getDbObject());\r
+ scheduledJob.setJobEngine(jobEngine);\r
+ for (int i = 0; i < 1; i++) {\r
+\r
+ try {\r
+ if (!scheduledJob.isActive())\r
+ scheduler.register(scheduledJob);\r
+ scheduler.executeImmediate(scheduledJob.getJobId());\r
+ Thread.sleep(300);\r
+ } catch (Exception e) {\r
+ Messagebox.show(e.getMessage());\r
+ }\r
+ }\r
+\r
}\r
- }\r
+ };\r
\r
+ new Thread(r).start();\r
close();\r
}\r
\r
<?xml version="1.0" encoding="UTF-8"?>\r
<classpath>\r
- <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.8"/>\r
<classpathentry kind="con" path="org.eclipse.pde.core.requiredPlugins"/>\r
<classpathentry kind="src" path="src"/>\r
+ <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>\r
<classpathentry kind="output" path="bin"/>\r
</classpath>\r
<?xml version="1.0" encoding="UTF-8"?>\r
<classpath>\r
- <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-1.7"/>\r
<classpathentry kind="con" path="org.eclipse.pde.core.requiredPlugins"/>\r
<classpathentry kind="src" path="src"/>\r
+ <classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER"/>\r
<classpathentry kind="output" path="bin"/>\r
</classpath>\r