Interface PropagationTaskExecutor
-
- All Known Implementing Classes:
AbstractPropagationTaskExecutor
,PriorityPropagationTaskExecutor
public interface PropagationTaskExecutor
Execute propagation tasks.- See Also:
PropagationTaskTO
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description PropagationReporter
execute(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
.void
expireRetryTemplate(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
-
-