public class DefaultJobStatusManager extends Object implements JobStatusManagerService
Constructor and Description |
---|
DefaultJobStatusManager(ServicesManager servicesManager) |
Modifier and Type | Method and Description |
---|---|
JobStatus |
createJobStatus(long jobInstanceId)
This method creates an entry for a new job instance
|
StepStatus |
createStepStatus(long stepExecutionId)
Creates an entry for the step in the stepstatus table during jobsetup
|
JobStatus |
getJobStatus(long jobInstanceId)
Returns the JobStatus for a given jobInstance id
|
JobStatus |
getJobStatusFromExecutionId(long executionId) |
StepStatus |
getStepStatus(long jobInstanceId,
String stepId) |
void |
init(Properties batchConfig) |
String |
toString() |
void |
updateJobBatchStatus(long jobInstanceId,
javax.batch.runtime.BatchStatus batchStatus) |
void |
updateJobCurrentStep(long jobInstanceId,
String currentStepName) |
void |
updateJobExecutionStatus(long jobInstanceId,
javax.batch.runtime.BatchStatus batchStatus,
String exitStatus) |
void |
updateJobStatus(JobStatus jobStatus) |
void |
updateJobStatusFromJSLStop(long jobInstanceId,
String restartOn) |
void |
updateJobStatusWithNewExecution(long jobInstanceId,
long newExecutionId) |
void |
updateStepStatus(long stepExecutionId,
StepStatus newStepStatus) |
public DefaultJobStatusManager(ServicesManager servicesManager)
public JobStatus createJobStatus(long jobInstanceId) throws BatchContainerServiceException
JobStatusManagerService
createJobStatus
in interface JobStatusManagerService
BatchContainerServiceException
public JobStatus getJobStatus(long jobInstanceId) throws BatchContainerServiceException
JobStatusManagerService
getJobStatus
in interface JobStatusManagerService
BatchContainerServiceException
public void updateJobStatus(JobStatus jobStatus)
updateJobStatus
in interface JobStatusManagerService
public JobStatus getJobStatusFromExecutionId(long executionId) throws BatchContainerServiceException
getJobStatusFromExecutionId
in interface JobStatusManagerService
BatchContainerServiceException
public void updateJobBatchStatus(long jobInstanceId, javax.batch.runtime.BatchStatus batchStatus) throws BatchContainerServiceException
updateJobBatchStatus
in interface JobStatusManagerService
BatchContainerServiceException
public void updateJobExecutionStatus(long jobInstanceId, javax.batch.runtime.BatchStatus batchStatus, String exitStatus) throws BatchContainerServiceException
updateJobExecutionStatus
in interface JobStatusManagerService
BatchContainerServiceException
public void updateJobCurrentStep(long jobInstanceId, String currentStepName) throws BatchContainerServiceException
updateJobCurrentStep
in interface JobStatusManagerService
BatchContainerServiceException
public void updateJobStatusWithNewExecution(long jobInstanceId, long newExecutionId) throws BatchContainerServiceException
updateJobStatusWithNewExecution
in interface JobStatusManagerService
BatchContainerServiceException
public StepStatus createStepStatus(long stepExecutionId) throws BatchContainerServiceException
JobStatusManagerService
createStepStatus
in interface JobStatusManagerService
BatchContainerServiceException
public StepStatus getStepStatus(long jobInstanceId, String stepId) throws BatchContainerServiceException
getStepStatus
in interface JobStatusManagerService
BatchContainerServiceException
public void updateStepStatus(long stepExecutionId, StepStatus newStepStatus)
updateStepStatus
in interface JobStatusManagerService
public void init(Properties batchConfig) throws BatchContainerServiceException
init
in interface BatchService
BatchContainerServiceException
public void updateJobStatusFromJSLStop(long jobInstanceId, String restartOn) throws BatchContainerServiceException
updateJobStatusFromJSLStop
in interface JobStatusManagerService
BatchContainerServiceException
Copyright © 2017 The Apache Software Foundation. All rights reserved.