public final class InfinispanRepository extends AbstractRepository
Constructor and Description |
---|
InfinispanRepository(org.infinispan.configuration.cache.Configuration infinispanConfig) |
InfinispanRepository(String infinispanXml) |
Modifier and Type | Method and Description |
---|---|
void |
addPartitionExecution(StepExecutionImpl enclosingStepExecution,
PartitionExecutionImpl partitionExecution) |
int |
countStepStartTimes(String stepName,
long jobInstanceId) |
static InfinispanRepository |
create(org.infinispan.configuration.cache.Configuration infinispanConfig) |
static InfinispanRepository |
create(Properties configProperties) |
JobExecutionImpl |
createJobExecution(JobInstanceImpl jobInstance,
Properties jobParameters) |
JobInstanceImpl |
createJobInstance(Job job,
String applicationName,
ClassLoader classLoader) |
StepExecutionImpl |
findOriginalStepExecutionForRestart(String stepName,
JobExecutionImpl jobExecutionToRestart0,
ClassLoader classLoader) |
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<PartitionExecutionImpl> |
getPartitionExecutions(long stepExecutionId,
StepExecutionImpl stepExecution,
boolean notCompletedOnly,
ClassLoader classLoader) |
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 |
savePersistentData(javax.batch.runtime.JobExecution jobExecution,
AbstractStepExecution stepOrPartitionExecution) |
void |
updateJobExecution(JobExecutionImpl jobExecution,
boolean fullUpdate,
boolean saveJobParameters) |
void |
updateStepExecution(javax.batch.runtime.StepExecution stepExecution) |
addJob, addStepExecution, createStepExecution, getJob, getJobNames, jobExists
public InfinispanRepository(org.infinispan.configuration.cache.Configuration infinispanConfig)
public InfinispanRepository(String infinispanXml)
public static InfinispanRepository create(org.infinispan.configuration.cache.Configuration infinispanConfig)
public static InfinispanRepository create(Properties configProperties)
public void removeJob(String jobId)
removeJob
in interface JobRepository
removeJob
in class AbstractRepository
public JobInstanceImpl createJobInstance(Job job, String applicationName, ClassLoader classLoader)
public void removeJobInstance(long jobInstanceIdToRemove)
public void removeJobExecutions(JobExecutionSelector jobExecutionSelector)
JobRepository
jobExecutionSelector
.jobExecutionSelector
- criteria for which JobExecutions to removepublic 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 void savePersistentData(javax.batch.runtime.JobExecution jobExecution, AbstractStepExecution stepOrPartitionExecution)
savePersistentData
in interface JobRepository
savePersistentData
in class AbstractRepository
public void updateStepExecution(javax.batch.runtime.StepExecution stepExecution)
public void updateJobExecution(JobExecutionImpl jobExecution, boolean fullUpdate, boolean saveJobParameters)
updateJobExecution
in interface JobRepository
updateJobExecution
in class AbstractRepository
public StepExecutionImpl findOriginalStepExecutionForRestart(String stepName, JobExecutionImpl jobExecutionToRestart0, ClassLoader classLoader)
public void addPartitionExecution(StepExecutionImpl enclosingStepExecution, PartitionExecutionImpl partitionExecution)
addPartitionExecution
in interface JobRepository
addPartitionExecution
in class AbstractRepository
public List<PartitionExecutionImpl> getPartitionExecutions(long stepExecutionId, StepExecutionImpl stepExecution, boolean notCompletedOnly, ClassLoader classLoader)
getPartitionExecutions
in interface JobRepository
getPartitionExecutions
in class AbstractRepository
public int countStepStartTimes(String stepName, long jobInstanceId)
public List<Long> getRunningExecutions(String jobName)
JobRepository
jobName
- the name of the job, not nullJobOperatorImpl.getRunningExecutions(java.lang.String)
Copyright © 2016 JBoss by Red Hat. All rights reserved.