public class PriorityPropagationTaskExecutor extends AbstractPropagationTaskExecutor
ExternalResource
's priority, then execute.
Tasks related to resources with NULL priority are executed after other tasks, concurrently.
Failure during execution of a task related to resource with non-NULL priority are treated as fatal and will interrupt
the whole process, resulting in a global failure.Modifier and Type | Field and Description |
---|---|
protected ThreadPoolTaskExecutor |
executor |
anyObjectDAO, anyUtilsFactory, auditManager, connFactory, connObjectUtils, entityFactory, groupDAO, LOG, notificationManager, outboundMatcher, publisher, resourceDAO, retryTemplates, taskDAO, taskDataBinder, taskUtilsFactory, userDAO, validator
MANDATORY_MISSING_ATTR_NAME, MANDATORY_NULL_OR_EMPTY_ATTR_NAME
Constructor and Description |
---|
PriorityPropagationTaskExecutor() |
Modifier and Type | Method and Description |
---|---|
PropagationReporter |
execute(Collection<PropagationTaskInfo> taskInfos,
boolean nullPriorityAsync)
Execute the given collection of tasks.
|
protected PropagationTaskCallable |
newPropagationTaskCallable(PropagationTaskInfo taskInfo,
PropagationReporter reporter)
Creates new instances of
PropagationTaskCallable for usage with
CompletionService . |
buildTask, createOrUpdate, delete, doExecute, execute, expireRetryTemplate, getPropagationActions, getRemoteObject, getRemoteObject, hasToBeregistered, rejected, retryTemplate
protected ThreadPoolTaskExecutor executor
protected PropagationTaskCallable newPropagationTaskCallable(PropagationTaskInfo taskInfo, PropagationReporter reporter)
PropagationTaskCallable
for usage with
CompletionService
.taskInfo
- to be executedreporter
- to report propagation execution statusPropagationTaskCallable
instance for usage with
CompletionService
public PropagationReporter execute(Collection<PropagationTaskInfo> taskInfos, boolean nullPriorityAsync)
PropagationTaskExecutor
taskInfos
- to be execute, in given ordernullPriorityAsync
- asynchronously executes tasks related to resources with no priorityCopyright © 2010–2023 The Apache Software Foundation. All rights reserved.