@Test public void testCreateJobSubmission() { HttpEventContext testCtx = new HttpEventContext(); testCtx.setUsername("testUser"); MSubmission jobSubmission = jobManager.createJobSubmission(testCtx, 1234L); assertEquals(jobSubmission.getCreationUser(), "testUser"); assertEquals(jobSubmission.getLastUpdateUser(), "testUser"); }
public MSubmission createJobSubmission(HttpEventContext ctx, long jobId) { MSubmission summary = new MSubmission(jobId); summary.setCreationUser(ctx.getUsername()); summary.setLastUpdateUser(ctx.getUsername()); return summary; }
JobManager implements Reconfigurable { public MSubmission createJobSubmission(HttpEventContext ctx, long jobId) { MSubmission summary = new MSubmission(jobId); summary.setCreationUser(ctx.getUsername()); summary.setLastUpdateUser(ctx.getUsername()); return summary; } }
JobManager implements Reconfigurable { public MSubmission createJobSubmission(HttpEventContext ctx, long jobId) { MSubmission summary = new MSubmission(jobId); summary.setCreationUser(ctx.getUsername()); summary.setLastUpdateUser(ctx.getUsername()); return summary; }  }
JobManager implements Reconfigurable { public MSubmission createJobSubmission(HttpEventContext ctx, long jobId) { MSubmission summary = new MSubmission(jobId); summary.setCreationUser(ctx.getUsername()); summary.setLastUpdateUser(ctx.getUsername()); return summary; }  static JobManager getInstance(); static void setInstance(JobManager newInstance); void setNotificationBaseUrl(String url); String getNotificationBaseUrl(); synchronized void destroy(); synchronized void initialize(); MSubmission start(long jobId, HttpEventContext ctx); JobRequest createJobRequest(long jobId, MSubmission submission); MSubmission createJobSubmission(HttpEventContext ctx, long jobId); void prepareJob(JobRequest request); MSubmission stop(long jobId, HttpEventContext ctx); MSubmission status(long jobId); void updateSubmission(MSubmission submission); @Override synchronized void configurationChanged(); }
JobManager implements Reconfigurable { public MSubmission createJobSubmission(HttpEventContext ctx, long jobId) { MSubmission summary = new MSubmission(jobId); summary.setCreationUser(ctx.getUsername()); summary.setLastUpdateUser(ctx.getUsername()); return summary; }  static JobManager getInstance(); static void setInstance(JobManager newInstance); void setNotificationBaseUrl(String url); String getNotificationBaseUrl(); synchronized void destroy(); synchronized void initialize(); MSubmission start(long jobId, HttpEventContext ctx); JobRequest createJobRequest(long jobId, MSubmission submission); MSubmission createJobSubmission(HttpEventContext ctx, long jobId); void prepareJob(JobRequest request); MSubmission stop(long jobId, HttpEventContext ctx); MSubmission status(long jobId); void updateSubmission(MSubmission submission); @Override synchronized void configurationChanged();  }