Class DefaultJobStatusManager
- java.lang.Object
-
- org.apache.batchee.container.services.status.DefaultJobStatusManager
-
- All Implemented Interfaces:
JobStatusManagerService,BatchService
public class DefaultJobStatusManager extends Object implements JobStatusManagerService
-
-
Constructor Summary
Constructors Constructor Description DefaultJobStatusManager(ServicesManager servicesManager)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description JobStatuscreateJobStatus(long jobInstanceId)This method creates an entry for a new job instanceStepStatuscreateStepStatus(long stepExecutionId)Creates an entry for the step in the stepstatus table during jobsetupJobStatusgetJobStatus(long jobInstanceId)Returns the JobStatus for a given jobInstance idJobStatusgetJobStatusFromExecutionId(long executionId)StepStatusgetStepStatus(long jobInstanceId, String stepId)voidinit(Properties batchConfig)StringtoString()voidupdateJobBatchStatus(long jobInstanceId, javax.batch.runtime.BatchStatus batchStatus)voidupdateJobCurrentStep(long jobInstanceId, String currentStepName)voidupdateJobExecutionStatus(long jobInstanceId, javax.batch.runtime.BatchStatus batchStatus, String exitStatus)voidupdateJobStatus(JobStatus jobStatus)voidupdateJobStatusFromJSLStop(long jobInstanceId, String restartOn)voidupdateJobStatusWithNewExecution(long jobInstanceId, long newExecutionId)voidupdateStepStatus(long stepExecutionId, StepStatus newStepStatus)
-
-
-
Constructor Detail
-
DefaultJobStatusManager
public DefaultJobStatusManager(ServicesManager servicesManager)
-
-
Method Detail
-
createJobStatus
public JobStatus createJobStatus(long jobInstanceId) throws BatchContainerServiceException
Description copied from interface:JobStatusManagerServiceThis method creates an entry for a new job instance- Specified by:
createJobStatusin interfaceJobStatusManagerService- Throws:
BatchContainerServiceException
-
getJobStatus
public JobStatus getJobStatus(long jobInstanceId) throws BatchContainerServiceException
Description copied from interface:JobStatusManagerServiceReturns the JobStatus for a given jobInstance id- Specified by:
getJobStatusin interfaceJobStatusManagerService- Returns:
- Throws:
BatchContainerServiceException
-
updateJobStatus
public void updateJobStatus(JobStatus jobStatus)
- Specified by:
updateJobStatusin interfaceJobStatusManagerService
-
getJobStatusFromExecutionId
public JobStatus getJobStatusFromExecutionId(long executionId) throws BatchContainerServiceException
- Specified by:
getJobStatusFromExecutionIdin interfaceJobStatusManagerService- Throws:
BatchContainerServiceException
-
updateJobBatchStatus
public void updateJobBatchStatus(long jobInstanceId, javax.batch.runtime.BatchStatus batchStatus) throws BatchContainerServiceException- Specified by:
updateJobBatchStatusin interfaceJobStatusManagerService- Throws:
BatchContainerServiceException
-
updateJobExecutionStatus
public void updateJobExecutionStatus(long jobInstanceId, javax.batch.runtime.BatchStatus batchStatus, String exitStatus) throws BatchContainerServiceException- Specified by:
updateJobExecutionStatusin interfaceJobStatusManagerService- Throws:
BatchContainerServiceException
-
updateJobCurrentStep
public void updateJobCurrentStep(long jobInstanceId, String currentStepName) throws BatchContainerServiceException- Specified by:
updateJobCurrentStepin interfaceJobStatusManagerService- Throws:
BatchContainerServiceException
-
updateJobStatusWithNewExecution
public void updateJobStatusWithNewExecution(long jobInstanceId, long newExecutionId) throws BatchContainerServiceException- Specified by:
updateJobStatusWithNewExecutionin interfaceJobStatusManagerService- Throws:
BatchContainerServiceException
-
createStepStatus
public StepStatus createStepStatus(long stepExecutionId) throws BatchContainerServiceException
Description copied from interface:JobStatusManagerServiceCreates an entry for the step in the stepstatus table during jobsetup- Specified by:
createStepStatusin interfaceJobStatusManagerService- Throws:
BatchContainerServiceException
-
getStepStatus
public StepStatus getStepStatus(long jobInstanceId, String stepId) throws BatchContainerServiceException
- Specified by:
getStepStatusin interfaceJobStatusManagerService- Throws:
BatchContainerServiceException
-
updateStepStatus
public void updateStepStatus(long stepExecutionId, StepStatus newStepStatus)- Specified by:
updateStepStatusin interfaceJobStatusManagerService
-
init
public void init(Properties batchConfig) throws BatchContainerServiceException
- Specified by:
initin interfaceBatchService- Throws:
BatchContainerServiceException
-
updateJobStatusFromJSLStop
public void updateJobStatusFromJSLStop(long jobInstanceId, String restartOn) throws BatchContainerServiceException- Specified by:
updateJobStatusFromJSLStopin interfaceJobStatusManagerService- Throws:
BatchContainerServiceException
-
-