git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube...
authorVásáry Dániel <daniel.vasary@userrendszerhaz.hu>
Tue, 13 Aug 2019 12:33:51 +0000 (12:33 +0000)
committerVásáry Dániel <daniel.vasary@userrendszerhaz.hu>
Tue, 13 Aug 2019 12:33:51 +0000 (12:33 +0000)
server/user.jobengine.osgi.server/src/user/jobengine/server/IJobEngine.java
server/user.jobengine.osgi.server/src/user/jobengine/server/JobEngine.java

index e6f53d7c36452d0cd5c90f7cacd4d0e9d2589f7b..e19b7316bde80860b44e247fa5b51a5fabbc9fbb 100644 (file)
@@ -113,6 +113,8 @@ public interface IJobEngine {
 
        IJobRuntime submit(String template, String name, Map<String, Object> parameters) throws JobEngineException;
 
+       IJobRuntime submit(String template, String name, Map<String, Object> parameters, String owner) throws JobEngineException;
+
        void suspendJob(Throwable t, IJobRuntime jobRuntime);
 
 }
index fca180545b752ffea717bc335edd6be34c6ee2dc..582c7e021fc40d099cd9140710cece0e94d40dbf 100644 (file)
@@ -864,6 +864,26 @@ public class JobEngine implements IJobEngine {
                return result;
        }
 
+       @Override
+       public IJobRuntime submit(String template, String name, Map<String, Object> parameters, String owner) throws JobEngineException {
+               IJobRuntime result = null;
+               IProgram program = getProgram(template);
+               if (program != null) {
+                       isRunnable(program);
+                       result = new JobRuntime(this, program);
+                       result.setPersister(itemManager);
+                       result.setOwner(owner);
+                       result.setTemplate(template);
+                       result.setName(name == null ? program.getTemplate().getName() : name);
+                       result.setParameters(parameters);
+                       result.setService(program.getTemplate().isService());
+                       submit(result);
+               } else {
+                       logger.error("Unknown template: " + template);
+               }
+               return result;
+       }
+
        @Override
        public void suspendJob(Throwable t, IJobRuntime jobRuntime) {
                String description = t.getClass().getSimpleName() + ": " + t.getMessage();