public class MemoryJobRepository extends Object implements JobRepository
JobRepository that uses an internal
ConcurrentHashMap for persisting its JobSpecs.| Constructor and Description |
|---|
MemoryJobRepository() |
| Modifier and Type | Method and Description |
|---|---|
String |
addJob(JobSpec spec) |
JobSpec |
getJobById(String jobId) |
String |
getStatus(JobSpec spec) |
boolean |
jobFinished(JobSpec spec) |
void |
removeJob(JobSpec spec) |
void |
updateJob(JobSpec spec) |
public String addJob(JobSpec spec) throws JobRepositoryException
addJob in interface JobRepositoryJobRepositoryExceptionpublic String getStatus(JobSpec spec) throws JobRepositoryException
getStatus in interface JobRepositoryJobRepositoryExceptionpublic boolean jobFinished(JobSpec spec) throws JobRepositoryException
jobFinished in interface JobRepositoryJobRepositoryExceptionpublic void removeJob(JobSpec spec) throws JobRepositoryException
removeJob in interface JobRepositoryJobRepositoryExceptionpublic void updateJob(JobSpec spec) throws JobRepositoryException
updateJob in interface JobRepositoryJobRepositoryExceptionpublic JobSpec getJobById(String jobId) throws JobRepositoryException
getJobById in interface JobRepositoryJobRepositoryExceptionCopyright © 1999–2017 Apache OODT. All rights reserved.