Package org.apache.syncope.core.provisioning.java.propagation

Class PriorityPropagationTaskExecutor

java.lang.Object

org.apache.syncope.core.provisioning.java.propagation.AbstractPropagationTaskExecutor

org.apache.syncope.core.provisioning.java.propagation.PriorityPropagationTaskExecutor

All Implemented Interfaces:

PropagationTaskExecutor

Direct Known Subclasses:

InstrumentedPriorityPropagationTaskExecutor

public class PriorityPropagationTaskExecutor
extends AbstractPropagationTaskExecutor

Sorts the tasks to be executed according to related 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.

Field Summary

Fields

Modifier and Type	Field	Description
protected final AsyncTaskExecutor	taskExecutor

Fields inherited from class org.apache.syncope.core.provisioning.java.propagation.AbstractPropagationTaskExecutor

anyUtilsFactory, auditManager, connectorManager, connObjectUtils, LOG, notificationManager, outboundMatcher, perContextActions, plainSchemaDAO, publisher, resourceDAO, retryTemplates, taskDAO, taskDataBinder, taskUtilsFactory, validator

Constructor Summary

Constructors

Constructor

Description

PriorityPropagationTaskExecutor(ConnectorManager connectorManager, ConnObjectUtils connObjectUtils, TaskDAO taskDAO, ExternalResourceDAO resourceDAO, PlainSchemaDAO plainSchemaDAO, NotificationManager notificationManager, AuditManager auditManager, TaskDataBinder taskDataBinder, AnyUtilsFactory anyUtilsFactory, TaskUtilsFactory taskUtilsFactory, OutboundMatcher outboundMatcher, PlainAttrValidationManager validator, ApplicationEventPublisher publisher, AsyncTaskExecutor taskExecutor)

Method Summary

Modifier and Type	Method	Description
PropagationReporter	execute(Collection<PropagationTaskInfo> taskInfos, boolean nullPriorityAsync, String executor)	Execute the given collection of tasks.
protected boolean	failed(PropagationTaskInfo taskInfpo, TaskExec<PropagationTask> exec, ExecStatus execStatus)
protected Callable<TaskExec<PropagationTask>>	newPropagationTaskCallable(PropagationTaskInfo taskInfo, PropagationReporter reporter, String executor)	Creates new instances of Callable for usage withCompletionService.

Methods inherited from class org.apache.syncope.core.provisioning.java.propagation.AbstractPropagationTaskExecutor

checkMandatoryMissing, createOrUpdate, delete, doCreate, doExecute, doUpdate, doUpdateDelta, execute, expireRetryTemplate, getPropagationActions, getRemoteObject, getRemoteObject, hasToBeregistered, isFetchRemoteObj, rejected, retryTemplate

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

taskExecutor

protected final AsyncTaskExecutor taskExecutor

Constructor Details

PriorityPropagationTaskExecutor

public PriorityPropagationTaskExecutor(ConnectorManager connectorManager,
 ConnObjectUtils connObjectUtils,
 TaskDAO taskDAO,
 ExternalResourceDAO resourceDAO,
 PlainSchemaDAO plainSchemaDAO,
 NotificationManager notificationManager,
 AuditManager auditManager,
 TaskDataBinder taskDataBinder,
 AnyUtilsFactory anyUtilsFactory,
 TaskUtilsFactory taskUtilsFactory,
 OutboundMatcher outboundMatcher,
 PlainAttrValidationManager validator,
 ApplicationEventPublisher publisher,
 AsyncTaskExecutor taskExecutor)

Method Details

newPropagationTaskCallable

protected Callable<TaskExec<PropagationTask>> newPropagationTaskCallable(PropagationTaskInfo taskInfo,
 PropagationReporter reporter,
 String executor)

Creates new instances of Callable for usage withCompletionService.

Parameters:

taskInfo - to be executed

reporter - to report propagation execution status

executor - user that triggered the propagation execution

Returns:

new Callable instance for usage with CompletionService

failed

protected boolean failed(PropagationTaskInfo taskInfpo,
 TaskExec<PropagationTask> exec,
 ExecStatus execStatus)

execute

public PropagationReporter execute(Collection<PropagationTaskInfo> taskInfos,
 boolean nullPriorityAsync,
 String executor)

Description copied from interface: PropagationTaskExecutor

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