@Test public void assertFindJobExecutionEvent() { storage.addJobExecutionEvent(new JobExecutionEvent("localhost", "127.0.0.1", "fake_task_id", "test_job", JobExecutionEvent.ExecutionSource.NORMAL_TRIGGER, 0)); }
public boolean addJobExecutionEvent(final JobExecutionEvent jobExecutionEvent) { if (null == jobExecutionEvent.getCompleteTime()) { return insertJobExecutionEvent(jobExecutionEvent); } else { if (jobExecutionEvent.isSuccess()) { return updateJobExecutionEventWhenSuccess(jobExecutionEvent); } else { return updateJobExecutionEventFailure(jobExecutionEvent); } } }
RDBJobEventStorage { public boolean addJobExecutionEvent(final JobExecutionEvent jobExecutionEvent) { if (null == jobExecutionEvent.getCompleteTime()) { return insertJobExecutionEvent(jobExecutionEvent); } else { if (jobExecutionEvent.isSuccess()) { return updateJobExecutionEventWhenSuccess(jobExecutionEvent); } else { return updateJobExecutionEventFailure(jobExecutionEvent); } } } }
RDBJobEventStorage { public boolean addJobExecutionEvent(final JobExecutionEvent jobExecutionEvent) { if (null == jobExecutionEvent.getCompleteTime()) { return insertJobExecutionEvent(jobExecutionEvent); } else { if (jobExecutionEvent.isSuccess()) { return updateJobExecutionEventWhenSuccess(jobExecutionEvent); } else { return updateJobExecutionEventFailure(jobExecutionEvent); } } } RDBJobEventStorage(final DataSource dataSource); }
RDBJobEventStorage { public boolean addJobExecutionEvent(final JobExecutionEvent jobExecutionEvent) { if (null == jobExecutionEvent.getCompleteTime()) { return insertJobExecutionEvent(jobExecutionEvent); } else { if (jobExecutionEvent.isSuccess()) { return updateJobExecutionEventWhenSuccess(jobExecutionEvent); } else { return updateJobExecutionEventFailure(jobExecutionEvent); } } } RDBJobEventStorage(final DataSource dataSource); boolean addJobExecutionEvent(final JobExecutionEvent jobExecutionEvent); boolean addJobStatusTraceEvent(final JobStatusTraceEvent jobStatusTraceEvent); }
RDBJobEventStorage { public boolean addJobExecutionEvent(final JobExecutionEvent jobExecutionEvent) { if (null == jobExecutionEvent.getCompleteTime()) { return insertJobExecutionEvent(jobExecutionEvent); } else { if (jobExecutionEvent.isSuccess()) { return updateJobExecutionEventWhenSuccess(jobExecutionEvent); } else { return updateJobExecutionEventFailure(jobExecutionEvent); } } } RDBJobEventStorage(final DataSource dataSource); boolean addJobExecutionEvent(final JobExecutionEvent jobExecutionEvent); boolean addJobStatusTraceEvent(final JobStatusTraceEvent jobStatusTraceEvent);  }