public class MemoryJobRepository extends Object implements JobRepository
JobRepository
that uses an internal
ConcurrentHashMap
for persisting its JobSpec
s.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 JobRepository
JobRepositoryException
public String getStatus(JobSpec spec) throws JobRepositoryException
getStatus
in interface JobRepository
JobRepositoryException
public boolean jobFinished(JobSpec spec) throws JobRepositoryException
jobFinished
in interface JobRepository
JobRepositoryException
public void removeJob(JobSpec spec) throws JobRepositoryException
removeJob
in interface JobRepository
JobRepositoryException
public void updateJob(JobSpec spec) throws JobRepositoryException
updateJob
in interface JobRepository
JobRepositoryException
public JobSpec getJobById(String jobId) throws JobRepositoryException
getJobById
in interface JobRepository
JobRepositoryException
Copyright © 1999–2017 Apache OODT. All rights reserved.