Interface PropagationTaskExecutor
-
- All Known Implementing Classes:
AbstractPropagationTaskExecutor,PriorityPropagationTaskExecutor
public interface PropagationTaskExecutorExecute propagation tasks.- See Also:
PropagationTaskTO
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description PropagationReporterexecute(Collection<PropagationTaskInfo> taskInfos, boolean nullPriorityAsync, String executor)Execute the given collection of tasks.TaskExec<PropagationTask>execute(PropagationTaskInfo taskInfo, PropagationReporter reporter, String executor)Execute the given task and returns the generatedTaskExec.voidexpireRetryTemplate(String resource)Remove any RetryTemplate defined for the given External Resource from local cache.
-
-
-
Method Detail
-
expireRetryTemplate
void expireRetryTemplate(String resource)
Remove any RetryTemplate defined for the given External Resource from local cache.- Parameters:
resource- External Resource name
-
execute
TaskExec<PropagationTask> execute(PropagationTaskInfo taskInfo, PropagationReporter reporter, String executor)
Execute the given task and returns the generatedTaskExec.- Parameters:
taskInfo- to be executedreporter- to report propagation execution statusexecutor- the executor of this task- Returns:
- the generated TaskExec
-
execute
PropagationReporter execute(Collection<PropagationTaskInfo> taskInfos, boolean nullPriorityAsync, String executor)
Execute the given collection of tasks. The process is interrupted as soon as the result of the communication with a resource with non-null priority is in error.- Parameters:
taskInfos- to be execute, in given ordernullPriorityAsync- asynchronously executes tasks related to resources with no priorityexecutor- the executor of this task- Returns:
- reporter to report propagation execution status
-
-