Package de.hybris.platform.task.impl
Class DefaultTaskExecutionStrategy
java.lang.Object
de.hybris.platform.task.impl.DefaultTaskExecutionStrategy
- All Implemented Interfaces:
TaskExecutionStrategy
- Direct Known Subclasses:
DefaultDataHubTaskExecutionStrategy,ProcessengineTaskExecutionStrategy,TriggerTaskExecutionStrategy
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidfinished(TaskService taskService, TaskRunner<TaskModel> runner, TaskModel model, Throwable error) Class<? extends TaskRunner<? extends TaskModel>>handleError(TaskService taskService, TaskRunner<TaskModel> runner, TaskModel model, Throwable error) handleRetry(TaskService taskService, TaskRunner<TaskModel> runner, TaskModel model, RetryLaterException retry, int currentRetries) protected RetryLaterExceptionvoidrun(TaskService taskService, TaskRunner<TaskModel> runner, TaskModel model) voidsetModelService(ModelService modelService) voidsetRunnerClass(Class<? extends TaskRunner<? extends TaskModel>> runnerClass) booleanwrapWithStrandedTasksLogic(TaskService taskService)
-
Field Details
-
TASK_RETRY_DELAY_CONFIG_KEY
- See Also:
-
-
Constructor Details
-
DefaultTaskExecutionStrategy
public DefaultTaskExecutionStrategy()
-
-
Method Details
-
getModelService
-
setModelService
-
finished
public void finished(TaskService taskService, TaskRunner<TaskModel> runner, TaskModel model, Throwable error) - Specified by:
finishedin interfaceTaskExecutionStrategy
-
wrapWithStrandedTasksLogic
-
handleError
public Throwable handleError(TaskService taskService, TaskRunner<TaskModel> runner, TaskModel model, Throwable error) - Specified by:
handleErrorin interfaceTaskExecutionStrategy
-
run
public void run(TaskService taskService, TaskRunner<TaskModel> runner, TaskModel model) throws RetryLaterException - Specified by:
runin interfaceTaskExecutionStrategy- Throws:
RetryLaterException
-
handleTransactionConnectionBrokenException
protected RetryLaterException handleTransactionConnectionBrokenException(TaskModel model, Exception e) -
handleRetry
public Date handleRetry(TaskService taskService, TaskRunner<TaskModel> runner, TaskModel model, RetryLaterException retry, int currentRetries) - Specified by:
handleRetryin interfaceTaskExecutionStrategy
-
setRunnerClass
-
getRunnerClass
- Specified by:
getRunnerClassin interfaceTaskExecutionStrategy
-