From 833f666c52c8e30082350029ecfac2027c09d532 Mon Sep 17 00:00:00 2001 From: =?utf8?q?V=C3=A1s=C3=A1ry=20D=C3=A1niel?= Date: Tue, 13 Aug 2019 12:33:51 +0000 Subject: [PATCH] git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube;C31474 --- .../src/user/jobengine/server/IJobEngine.java | 2 ++ .../src/user/jobengine/server/JobEngine.java | 20 +++++++++++++++++++ 2 files changed, 22 insertions(+) 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 parameters) throws JobEngineException; + IJobRuntime submit(String template, String name, Map 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 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(); -- 2.54.0