public final class InMemoryRepository extends AbstractRepository
Constructor and Description |
---|
InMemoryRepository() |
Modifier and Type | Method and Description |
---|---|
int |
countStepStartTimes(String stepName,
long jobInstanceId) |
static InMemoryRepository |
create()
Creates a new in-memory job repository.
|
JobExecutionImpl |
createJobExecution(JobInstanceImpl jobInstance,
Properties jobParameters) |
JobInstanceImpl |
createJobInstance(Job job,
String applicationName,
ClassLoader classLoader) |
StepExecutionImpl |
findOriginalStepExecutionForRestart(String stepName,
JobExecutionImpl jobExecutionToRestart,
ClassLoader classLoader) |
static InMemoryRepository |
getInstance()
Gets a singleton instance of an in-memory job repository.
|
JobExecutionImpl |
getJobExecution(long jobExecutionId) |
List<javax.batch.runtime.JobExecution> |
getJobExecutions(javax.batch.runtime.JobInstance jobInstance) |
javax.batch.runtime.JobInstance |
getJobInstance(long jobInstanceId) |
int |
getJobInstanceCount(String jobName) |
List<javax.batch.runtime.JobInstance> |
getJobInstances(String jobName) |
List<Long> |
getRunningExecutions(String jobName)
Gets the ids of running job executions belonging to a specific job.
|
List<javax.batch.runtime.StepExecution> |
getStepExecutions(long jobExecutionId,
ClassLoader classLoader) |
void |
removeJob(String jobId) |
void |
removeJobExecutions(JobExecutionSelector jobExecutionSelector)
Removes JobExecutions based on the criteria specified in
jobExecutionSelector . |
void |
removeJobInstance(long jobInstanceIdToRemove) |
void |
updateStepExecution(javax.batch.runtime.StepExecution stepExecution) |
addJob, addPartitionExecution, addStepExecution, createStepExecution, getJob, getJobNames, getPartitionExecutions, jobExists, savePersistentData, updateJobExecution
public static InMemoryRepository getInstance()
public static InMemoryRepository create()
public void removeJob(String jobId)
removeJob
in interface JobRepository
removeJob
in class AbstractRepository
public void updateStepExecution(javax.batch.runtime.StepExecution stepExecution)
public int countStepStartTimes(String stepName, long jobInstanceId)
public void removeJobExecutions(JobExecutionSelector jobExecutionSelector)
JobRepository
jobExecutionSelector
.jobExecutionSelector
- criteria for which JobExecutions to removepublic JobInstanceImpl createJobInstance(Job job, String applicationName, ClassLoader classLoader)
public void removeJobInstance(long jobInstanceIdToRemove)
public javax.batch.runtime.JobInstance getJobInstance(long jobInstanceId)
public int getJobInstanceCount(String jobName)
public JobExecutionImpl createJobExecution(JobInstanceImpl jobInstance, Properties jobParameters)
public JobExecutionImpl getJobExecution(long jobExecutionId)
public List<javax.batch.runtime.JobExecution> getJobExecutions(javax.batch.runtime.JobInstance jobInstance)
public List<javax.batch.runtime.StepExecution> getStepExecutions(long jobExecutionId, ClassLoader classLoader)
public StepExecutionImpl findOriginalStepExecutionForRestart(String stepName, JobExecutionImpl jobExecutionToRestart, ClassLoader classLoader)
public List<Long> getRunningExecutions(String jobName)
JobRepository
jobName
- the name of the job, not nullJobOperatorImpl.getRunningExecutions(java.lang.String)
Copyright © 2018 JBoss by Red Hat. All rights reserved.