Interface PropagationTaskExecutor
- All Known Implementing Classes:
AbstractPropagationTaskExecutor,InstrumentedPriorityPropagationTaskExecutor,PriorityPropagationTaskExecutor
public interface PropagationTaskExecutor
Execute propagation tasks.
- See Also:
-
Method Summary
Modifier and TypeMethodDescriptionexecute(Collection<PropagationTaskInfo> taskInfos, boolean nullPriorityAsync, String executor) Execute the given collection of tasks.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 Details
-
expireRetryTemplate
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
-