public class JdbcJobRepositoryService extends Object implements org.jboss.msc.service.Service<org.jberet.repository.JobRepository>
Constructor and Description |
---|
JdbcJobRepositoryService() |
Modifier and Type | Method and Description |
---|---|
void |
addJob(org.jberet.repository.ApplicationAndJobName applicationAndJobName,
org.jberet.job.model.Job job) |
void |
addPartitionExecution(org.jberet.runtime.StepExecutionImpl enclosingStepExecution,
org.jberet.runtime.PartitionExecutionImpl partitionExecution) |
void |
addStepExecution(org.jberet.runtime.JobExecutionImpl jobExecution,
org.jberet.runtime.StepExecutionImpl stepExecution) |
int |
countStepStartTimes(String stepName,
long jobInstanceId) |
org.jberet.runtime.JobExecutionImpl |
createJobExecution(org.jberet.runtime.JobInstanceImpl jobInstance,
Properties jobParameters) |
org.jberet.runtime.JobInstanceImpl |
createJobInstance(org.jberet.job.model.Job job,
String applicationName,
ClassLoader classLoader) |
org.jberet.runtime.StepExecutionImpl |
createStepExecution(String stepName) |
org.jberet.runtime.StepExecutionImpl |
findOriginalStepExecutionForRestart(String stepName,
org.jberet.runtime.JobExecutionImpl jobExecutionToRestart,
ClassLoader classLoader) |
protected org.jboss.msc.value.InjectedValue<DataSource> |
getDataSourceInjector() |
protected org.jberet.repository.JobRepository |
getDelegate() |
protected org.jboss.msc.inject.Injector<ExecutorService> |
getExecutorServiceInjector() |
org.jberet.job.model.Job |
getJob(org.jberet.repository.ApplicationAndJobName applicationAndJobName) |
javax.batch.runtime.JobExecution |
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) |
Set<String> |
getJobNames() |
List<org.jberet.runtime.PartitionExecutionImpl> |
getPartitionExecutions(long stepExecutionId,
org.jberet.runtime.StepExecutionImpl stepExecution,
boolean notCompletedOnly,
ClassLoader classLoader) |
List<Long> |
getRunningExecutions(String jobName) |
List<javax.batch.runtime.StepExecution> |
getStepExecutions(long jobExecutionId,
ClassLoader classLoader) |
org.jberet.repository.JobRepository |
getValue() |
boolean |
jobExists(String jobName) |
void |
removeJob(String jobId) |
void |
removeJobExecutions(org.jberet.repository.JobExecutionSelector jobExecutionSelector) |
void |
removeJobInstance(long jobInstanceId) |
void |
savePersistentData(javax.batch.runtime.JobExecution jobExecution,
org.jberet.runtime.AbstractStepExecution stepOrPartitionExecution) |
void |
start(org.jboss.msc.service.StartContext context) |
void |
startJobRepository(org.jboss.msc.service.StartContext context) |
void |
stop(org.jboss.msc.service.StopContext context) |
void |
stopJobRepository(org.jboss.msc.service.StopContext context) |
void |
updateJobExecution(org.jberet.runtime.JobExecutionImpl jobExecution,
boolean fullUpdate,
boolean saveJobParameters) |
void |
updateStepExecution(javax.batch.runtime.StepExecution stepExecution) |
public void startJobRepository(org.jboss.msc.service.StartContext context) throws org.jboss.msc.service.StartException
org.jboss.msc.service.StartException
public void stopJobRepository(org.jboss.msc.service.StopContext context)
protected org.jberet.repository.JobRepository getDelegate()
protected org.jboss.msc.value.InjectedValue<DataSource> getDataSourceInjector()
protected org.jboss.msc.inject.Injector<ExecutorService> getExecutorServiceInjector()
public final void start(org.jboss.msc.service.StartContext context) throws org.jboss.msc.service.StartException
start
in interface org.jboss.msc.service.Service<org.jberet.repository.JobRepository>
org.jboss.msc.service.StartException
public final void stop(org.jboss.msc.service.StopContext context)
stop
in interface org.jboss.msc.service.Service<org.jberet.repository.JobRepository>
public final org.jberet.repository.JobRepository getValue() throws IllegalStateException, IllegalArgumentException
getValue
in interface org.jboss.msc.value.Value<org.jberet.repository.JobRepository>
IllegalStateException
IllegalArgumentException
public void addJob(org.jberet.repository.ApplicationAndJobName applicationAndJobName, org.jberet.job.model.Job job)
addJob
in interface org.jberet.repository.JobRepository
public void removeJob(String jobId)
removeJob
in interface org.jberet.repository.JobRepository
public org.jberet.job.model.Job getJob(org.jberet.repository.ApplicationAndJobName applicationAndJobName)
getJob
in interface org.jberet.repository.JobRepository
public Set<String> getJobNames()
getJobNames
in interface org.jberet.repository.JobRepository
public boolean jobExists(String jobName)
jobExists
in interface org.jberet.repository.JobRepository
public org.jberet.runtime.JobInstanceImpl createJobInstance(org.jberet.job.model.Job job, String applicationName, ClassLoader classLoader)
createJobInstance
in interface org.jberet.repository.JobRepository
public void removeJobInstance(long jobInstanceId)
removeJobInstance
in interface org.jberet.repository.JobRepository
public javax.batch.runtime.JobInstance getJobInstance(long jobInstanceId)
getJobInstance
in interface org.jberet.repository.JobRepository
public List<javax.batch.runtime.JobInstance> getJobInstances(String jobName)
getJobInstances
in interface org.jberet.repository.JobRepository
public int getJobInstanceCount(String jobName)
getJobInstanceCount
in interface org.jberet.repository.JobRepository
public org.jberet.runtime.JobExecutionImpl createJobExecution(org.jberet.runtime.JobInstanceImpl jobInstance, Properties jobParameters)
createJobExecution
in interface org.jberet.repository.JobRepository
public javax.batch.runtime.JobExecution getJobExecution(long jobExecutionId)
getJobExecution
in interface org.jberet.repository.JobRepository
public List<javax.batch.runtime.JobExecution> getJobExecutions(javax.batch.runtime.JobInstance jobInstance)
getJobExecutions
in interface org.jberet.repository.JobRepository
public void updateJobExecution(org.jberet.runtime.JobExecutionImpl jobExecution, boolean fullUpdate, boolean saveJobParameters)
updateJobExecution
in interface org.jberet.repository.JobRepository
public List<Long> getRunningExecutions(String jobName)
getRunningExecutions
in interface org.jberet.repository.JobRepository
public void removeJobExecutions(org.jberet.repository.JobExecutionSelector jobExecutionSelector)
removeJobExecutions
in interface org.jberet.repository.JobRepository
public List<javax.batch.runtime.StepExecution> getStepExecutions(long jobExecutionId, ClassLoader classLoader)
getStepExecutions
in interface org.jberet.repository.JobRepository
public org.jberet.runtime.StepExecutionImpl createStepExecution(String stepName)
createStepExecution
in interface org.jberet.repository.JobRepository
public void addStepExecution(org.jberet.runtime.JobExecutionImpl jobExecution, org.jberet.runtime.StepExecutionImpl stepExecution)
addStepExecution
in interface org.jberet.repository.JobRepository
public void updateStepExecution(javax.batch.runtime.StepExecution stepExecution)
updateStepExecution
in interface org.jberet.repository.JobRepository
public org.jberet.runtime.StepExecutionImpl findOriginalStepExecutionForRestart(String stepName, org.jberet.runtime.JobExecutionImpl jobExecutionToRestart, ClassLoader classLoader)
findOriginalStepExecutionForRestart
in interface org.jberet.repository.JobRepository
public int countStepStartTimes(String stepName, long jobInstanceId)
countStepStartTimes
in interface org.jberet.repository.JobRepository
public void addPartitionExecution(org.jberet.runtime.StepExecutionImpl enclosingStepExecution, org.jberet.runtime.PartitionExecutionImpl partitionExecution)
addPartitionExecution
in interface org.jberet.repository.JobRepository
public List<org.jberet.runtime.PartitionExecutionImpl> getPartitionExecutions(long stepExecutionId, org.jberet.runtime.StepExecutionImpl stepExecution, boolean notCompletedOnly, ClassLoader classLoader)
getPartitionExecutions
in interface org.jberet.repository.JobRepository
public void savePersistentData(javax.batch.runtime.JobExecution jobExecution, org.jberet.runtime.AbstractStepExecution stepOrPartitionExecution)
savePersistentData
in interface org.jberet.repository.JobRepository
Copyright © 2018 JBoss by Red Hat. All rights reserved.