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 FindJobInstancesByJobNameReq |
buildFindJobInstancesByJobNameReq(java.lang.String jobName,
int start,
int count) |
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 FindJobInstancesByJobNameReq buildFindJobInstancesByJobNameReq(java.lang.String jobName, int start, int count)
public 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