public class DefaultJobRetryCmd extends JobRetryCmd
Modifier and Type | Field and Description |
---|---|
static List<String> |
SUPPORTED_TYPES |
exception, jobId, serialVersionUID
Constructor and Description |
---|
DefaultJobRetryCmd(String jobId,
Throwable exception) |
Modifier and Type | Method and Description |
---|---|
Object |
execute(CommandContext commandContext) |
protected void |
executeCustomStrategy(CommandContext commandContext,
JobEntity job,
ActivityImpl activity) |
protected void |
executeStandardStrategy(CommandContext commandContext) |
protected ExecutionEntity |
fetchExecutionEntity(String executionId) |
protected ActivityImpl |
getCurrentActivity(CommandContext commandContext,
JobEntity job) |
protected DurationHelper |
getDurationHelper(String failedJobRetryTimeCycle) |
protected FailedJobRetryConfiguration |
getFailedJobRetryConfiguration(JobEntity job,
ActivityImpl activity) |
protected String |
getFailedJobRetryTimeCycle(JobEntity job,
Expression expression) |
protected void |
initializeRetries(JobEntity job,
int retries) |
protected boolean |
isFirstJobExecution(JobEntity job) |
decrementRetries, getExceptionStacktrace, getJob, logException, notifyAcquisition, shouldDecrementRetriesFor
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isRetryable
public Object execute(CommandContext commandContext)
protected void executeStandardStrategy(CommandContext commandContext)
protected void executeCustomStrategy(CommandContext commandContext, JobEntity job, ActivityImpl activity) throws Exception
Exception
protected ActivityImpl getCurrentActivity(CommandContext commandContext, JobEntity job)
protected ExecutionEntity fetchExecutionEntity(String executionId)
protected FailedJobRetryConfiguration getFailedJobRetryConfiguration(JobEntity job, ActivityImpl activity)
protected String getFailedJobRetryTimeCycle(JobEntity job, Expression expression)
protected DurationHelper getDurationHelper(String failedJobRetryTimeCycle) throws Exception
Exception
protected boolean isFirstJobExecution(JobEntity job)
protected void initializeRetries(JobEntity job, int retries)
Copyright © 2022. All rights reserved.