public class JobRepositoryRpcFactory
extends java.lang.Object
| Constructor and Description |
|---|
JobRepositoryRpcFactory() |
| Modifier and Type | Method and Description |
|---|---|
static AddWithStepExecutionReq |
buildAddWithStepExecutionReq(org.springframework.batch.core.StepExecution stepExecution) |
static CreateJobExecutionReq |
buildCreateJobExecutionReq(java.lang.String jobName,
org.springframework.batch.core.JobParameters jobParameters) |
static CreateJobExecutionWithJobInstanceReq |
buildCreateJobExecutionWithJobInstanceReq(org.springframework.batch.core.JobInstance jobInstance,
org.springframework.batch.core.JobParameters jobParameters,
java.lang.String jobConfigurationLocation) |
static CreateJobInstanceReq |
buildCreateJobInstanceReq(java.lang.String jobName,
org.springframework.batch.core.JobParameters jobParameters) |
static FindRunningJobExecutionsReq |
buildFindRunningJobExecutionsReq(java.lang.String jobName) |
static GetJobExecutionReq |
buildGetJobExecutionReq(java.lang.Long executionId) |
static GetJobExecutionsReq |
buildGetJobExecutionsReq(org.springframework.batch.core.JobInstance jobInstance) |
static GetJobInstanceCountReq |
buildGetJobInstanceCountReq(java.lang.String jobName) |
static GetJobInstanceReq |
buildGetJobInstanceReq(java.lang.Long instanceId) |
static GetJobInstancesReq |
buildGetJobInstancesReq(java.lang.String jobName,
int start,
int count)
Builds request for getting a job instance by its name
and paging info.
|
static GetJobNamesReq |
buildGetJobNamesReq() |
static GetLastJobExecutionReq |
buildGetLastJobExecutionReq(java.lang.String jobName,
org.springframework.batch.core.JobParameters jobParameters) |
static GetLastStepExecutionReq |
buildGetLastStepExecutionReq(org.springframework.batch.core.JobInstance jobInstance,
java.lang.String stepName) |
static GetStepExecutionCountReq |
buildGetStepExecutionCountReq(org.springframework.batch.core.JobInstance jobInstance,
java.lang.String stepName) |
static GetStepExecutionReq |
buildGetStepExecutionReq(java.lang.Long jobExecutionId,
java.lang.Long stepExecutionId) |
static IsJobInstanceExistsReq |
buildIsJobInstanceExistsReq(java.lang.String jobName,
org.springframework.batch.core.JobParameters jobParameters) |
static UpdateWithJobExecutionReq |
buildSaveJobExecutionReq(org.springframework.batch.core.JobExecution jobExecution) |
static UpdateExecutionContextReq |
buildUpdateExecutionContextReq(org.springframework.batch.core.JobExecution jobExecution)
Builds request for updating execution context from a job execution.
|
static UpdateExecutionContextReq |
buildUpdateExecutionContextReq(org.springframework.batch.core.StepExecution stepExecution)
Builds request for updating execution context from a step execution.
|
static UpdateWithStepExecutionReq |
buildUpdateWithStepExecutionReq(org.springframework.batch.core.StepExecution stepExecution) |
static ExecutionContextType |
convertExecutionContext(org.springframework.batch.item.ExecutionContext executionContext)
Converts a
ExecutionContext to ExecutionContextType. |
static org.springframework.batch.item.ExecutionContext |
convertExecutionContextType(ExecutionContextType executionContextType)
Converts a
ExecutionContextType to ExecutionContext. |
static JobExecutionType |
convertJobExecutionType(org.springframework.batch.core.JobExecution jobExecution)
Creates
JobExecutionType from JobExecution. |
static JobExecutionType |
convertJobExecutionType(org.springframework.batch.core.JobExecution jobExecution,
org.springframework.batch.core.StepExecution stepExecution)
Creates
JobExecutionType from JobExecution. |
static org.springframework.batch.core.JobExecution |
convertJobExecutionType(JobExecutionType type)
Converts a
JobExecutionType to JobExecution. |
static JobInstanceType |
convertJobInstanceType(org.springframework.batch.core.JobInstance jobInstance)
Converts a
JobInstance to JobInstanceType. |
static org.springframework.batch.core.JobInstance |
convertJobInstanceType(JobInstanceType type)
Converts a
JobInstanceType to JobInstance. |
static JobParametersType |
convertJobParameters(org.springframework.batch.core.JobParameters jobParameters)
Converts a
JobParameters to JobParametersType. |
static org.springframework.batch.core.JobParameters |
convertJobParametersType(JobParametersType type)
Converts a
JobParametersType to JobParameters. |
static StepExecutionType |
convertStepExecutionType(org.springframework.batch.core.StepExecution stepExecution)
Creates
StepExecutionType from StepExecution. |
static StepExecutionType |
convertStepExecutionType(org.springframework.batch.core.StepExecution stepExecution,
org.springframework.batch.core.JobExecution jobExecution)
Creates
StepExecutionType from StepExecution. |
static org.springframework.batch.core.StepExecution |
convertStepExecutionType(StepExecutionType type)
Converts a
StepExecutionType to StepExecution. |
public static StepExecutionType convertStepExecutionType(org.springframework.batch.core.StepExecution stepExecution)
StepExecutionType from StepExecution.stepExecution - the step executionconvertStepExecutionType(StepExecution, JobExecution)public static StepExecutionType convertStepExecutionType(org.springframework.batch.core.StepExecution stepExecution, org.springframework.batch.core.JobExecution jobExecution)
StepExecutionType from StepExecution. Second
argument JobExecution is only used as a back reference to
prevent never ending loop for serialization logic due to references
between StepExecution and JobExecution.stepExecution - the step executionjobExecution - the job executionpublic static ExecutionContextType convertExecutionContext(org.springframework.batch.item.ExecutionContext executionContext)
ExecutionContext to ExecutionContextType.executionContext - the execution contextpublic static org.springframework.batch.item.ExecutionContext convertExecutionContextType(ExecutionContextType executionContextType)
ExecutionContextType to ExecutionContext.executionContextType - the execution context typepublic static org.springframework.batch.core.StepExecution convertStepExecutionType(StepExecutionType type)
StepExecutionType to StepExecution.type - the step execution typepublic static JobExecutionType convertJobExecutionType(org.springframework.batch.core.JobExecution jobExecution)
JobExecutionType from JobExecution.jobExecution - the job executionconvertJobExecutionType(JobExecution, StepExecution)public static JobExecutionType convertJobExecutionType(org.springframework.batch.core.JobExecution jobExecution, org.springframework.batch.core.StepExecution stepExecution)
JobExecutionType from JobExecution. Second
argument StepExecution is only used as a back reference to
prevent never ending loop for serialization logic due to references
between StepExecution and JobExecution.jobExecution - the job executionstepExecution - the step executionpublic static org.springframework.batch.core.JobExecution convertJobExecutionType(JobExecutionType type)
JobExecutionType to JobExecution.type - the job execution typepublic static JobInstanceType convertJobInstanceType(org.springframework.batch.core.JobInstance jobInstance)
JobInstance to JobInstanceType.jobInstance - the job instancepublic static org.springframework.batch.core.JobInstance convertJobInstanceType(JobInstanceType type)
JobInstanceType to JobInstance.type - the job instance typepublic static JobParametersType convertJobParameters(org.springframework.batch.core.JobParameters jobParameters)
JobParameters to JobParametersType.jobParameters - the job parameterspublic static org.springframework.batch.core.JobParameters convertJobParametersType(JobParametersType type)
JobParametersType to JobParameters.type - the job parameters typepublic static IsJobInstanceExistsReq buildIsJobInstanceExistsReq(java.lang.String jobName, org.springframework.batch.core.JobParameters jobParameters)
public static CreateJobExecutionReq buildCreateJobExecutionReq(java.lang.String jobName, org.springframework.batch.core.JobParameters jobParameters)
public static CreateJobInstanceReq buildCreateJobInstanceReq(java.lang.String jobName, org.springframework.batch.core.JobParameters jobParameters)
public static CreateJobExecutionWithJobInstanceReq buildCreateJobExecutionWithJobInstanceReq(org.springframework.batch.core.JobInstance jobInstance, org.springframework.batch.core.JobParameters jobParameters, java.lang.String jobConfigurationLocation)
public static UpdateWithJobExecutionReq buildSaveJobExecutionReq(org.springframework.batch.core.JobExecution jobExecution)
public static AddWithStepExecutionReq buildAddWithStepExecutionReq(org.springframework.batch.core.StepExecution stepExecution)
public static GetStepExecutionCountReq buildGetStepExecutionCountReq(org.springframework.batch.core.JobInstance jobInstance, java.lang.String stepName)
public static GetJobInstanceCountReq buildGetJobInstanceCountReq(java.lang.String jobName)
public static GetLastStepExecutionReq buildGetLastStepExecutionReq(org.springframework.batch.core.JobInstance jobInstance, java.lang.String stepName)
public static UpdateWithStepExecutionReq buildUpdateWithStepExecutionReq(org.springframework.batch.core.StepExecution stepExecution)
public static GetLastJobExecutionReq buildGetLastJobExecutionReq(java.lang.String jobName, org.springframework.batch.core.JobParameters jobParameters)
public static GetJobInstancesReq buildGetJobInstancesReq(java.lang.String jobName, int start, int count)
jobName - the job namestart - index where to startcount - max number of entries to requestGetJobInstancesReq requestpublic static GetJobInstanceReq buildGetJobInstanceReq(java.lang.Long instanceId)
public static GetJobExecutionReq buildGetJobExecutionReq(java.lang.Long executionId)
public static GetStepExecutionReq buildGetStepExecutionReq(java.lang.Long jobExecutionId, java.lang.Long stepExecutionId)
public static GetJobExecutionsReq buildGetJobExecutionsReq(org.springframework.batch.core.JobInstance jobInstance)
public static FindRunningJobExecutionsReq buildFindRunningJobExecutionsReq(java.lang.String jobName)
public static GetJobNamesReq buildGetJobNamesReq()
public static UpdateExecutionContextReq buildUpdateExecutionContextReq(org.springframework.batch.core.StepExecution stepExecution)
stepExecution - the step executionUpdateExecutionContextReq requestpublic static UpdateExecutionContextReq buildUpdateExecutionContextReq(org.springframework.batch.core.JobExecution jobExecution)
jobExecution - the job executionUpdateExecutionContextReq request