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);
}
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();