DefaultJobStatusStore implements JobStatusStore, Initializable { @Override public LoggerTail createLoggerTail(List<String> jobId, boolean readonly) { if (jobId != null) { try { return createLoggerTail(getJobLogBaseFile(jobId), readonly); } catch (Exception e) { this.logger.error("Failed to create a logger tail for job [{}]", jobId, e); } } return new LogQueue(); }  @Override void initialize(); @Override JobStatus getJobStatus(List<String> id); @Override void store(JobStatus status); @Override void storeAsync(JobStatus status); @Override void remove(List<String> id); @Override LoggerTail createLoggerTail(List<String> jobId, boolean readonly); void flushCache();  }
@Test void createLoggerTailWithNullId() { assertNotNull(this.store.createLoggerTail(null, true)); }