Package org.camunda.bpm.engine.impl.cmd

Class DefaultJobRetryCmd

java.lang.Object

org.camunda.bpm.engine.impl.cmd.JobRetryCmd

org.camunda.bpm.engine.impl.cmd.DefaultJobRetryCmd

All Implemented Interfaces:

Command<Object>

public class DefaultJobRetryCmd
extends JobRetryCmd

Author:

Roman Smirnov

Field Summary

Fields

Modifier and Type	Field	Description
static List<String>	SUPPORTED_TYPES

Fields inherited from class org.camunda.bpm.engine.impl.cmd.JobRetryCmd

exception, jobId, serialVersionUID

Constructor Summary

Constructors

Constructor	Description
DefaultJobRetryCmd(String jobId, Throwable exception)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class org.camunda.bpm.engine.impl.cmd.JobRetryCmd

decrementRetries, getExceptionStacktrace, getJob, logException, notifyAcquisition, shouldDecrementRetriesFor

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.camunda.bpm.engine.impl.interceptor.Command

isRetryable

Field Detail

SUPPORTED_TYPES

public static final List<String> SUPPORTED_TYPES

Constructor Detail

DefaultJobRetryCmd

public DefaultJobRetryCmd(String jobId,
                          Throwable exception)

Method Detail

execute

public Object execute(CommandContext commandContext)

executeStandardStrategy

protected void executeStandardStrategy(CommandContext commandContext)

executeCustomStrategy

protected void executeCustomStrategy(CommandContext commandContext,
                                     JobEntity job,
                                     ActivityImpl activity)
                              throws Exception

Throws:

Exception

getCurrentActivity

protected ActivityImpl getCurrentActivity(CommandContext commandContext,
                                          JobEntity job)

fetchExecutionEntity

protected ExecutionEntity fetchExecutionEntity(String executionId)

getFailedJobRetryConfiguration

protected FailedJobRetryConfiguration getFailedJobRetryConfiguration(JobEntity job,
                                                                     ActivityImpl activity)

getFailedJobRetryTimeCycle

protected String getFailedJobRetryTimeCycle(JobEntity job,
                                            Expression expression)

getDurationHelper

protected DurationHelper getDurationHelper(String failedJobRetryTimeCycle)
                                    throws Exception

Throws:

Exception

isFirstJobExecution

protected boolean isFirstJobExecution(JobEntity job)

initializeRetries

protected void initializeRetries(JobEntity job,
                                 int retries)