Interface PropagationTaskExecutor

All Known Implementing Classes:
AbstractPropagationTaskExecutor, InstrumentedPriorityPropagationTaskExecutor, PriorityPropagationTaskExecutor

public interface PropagationTaskExecutor
Execute propagation tasks.
See Also:
  • Method Details

    • 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 generated TaskExec.
      Parameters:
      taskInfo - to be executed
      reporter - to report propagation execution status
      executor - 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 order
      nullPriorityAsync - asynchronously executes tasks related to resources with no priority
      executor - the executor of this task
      Returns:
      reporter to report propagation execution status