From: Vásáry Dániel <daniel.vasary@userrendszerhaz.hu>
Date: Tue, 13 Aug 2019 12:33:51 +0000 (+0000)
Subject: git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube... 
X-Git-Url: http://git.useribm.hu/?a=commitdiff_plain;h=833f666c52c8e30082350029ecfac2027c09d532;p=mediacube.git

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

diff --git a/server/user.jobengine.osgi.server/src/user/jobengine/server/IJobEngine.java b/server/user.jobengine.osgi.server/src/user/jobengine/server/IJobEngine.java
index e6f53d7c..e19b7316 100644
--- a/server/user.jobengine.osgi.server/src/user/jobengine/server/IJobEngine.java
+++ b/server/user.jobengine.osgi.server/src/user/jobengine/server/IJobEngine.java
@@ -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);
 
 }
diff --git a/server/user.jobengine.osgi.server/src/user/jobengine/server/JobEngine.java b/server/user.jobengine.osgi.server/src/user/jobengine/server/JobEngine.java
index fca18054..582c7e02 100644
--- a/server/user.jobengine.osgi.server/src/user/jobengine/server/JobEngine.java
+++ b/server/user.jobengine.osgi.server/src/user/jobengine/server/JobEngine.java
@@ -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();