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

Class AbstractPropagationTaskExecutor

java.lang.Object

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

All Implemented Interfaces:

PropagationTaskExecutor

Direct Known Subclasses:

PriorityPropagationTaskExecutor

@Transactional(rollbackFor=java.lang.Throwable.class)
public abstract class AbstractPropagationTaskExecutor
extends Object
implements PropagationTaskExecutor

Field Summary

Fields

Modifier and Type	Field	Description
protected final AnyUtilsFactory	anyUtilsFactory
protected final AuditManager	auditManager
protected final ConnectorManager	connectorManager
protected final ConnObjectUtils	connObjectUtils
protected static final Logger	LOG
protected final NotificationManager	notificationManager
protected final OutboundMatcher	outboundMatcher
protected final Map<String,PropagationActions>	perContextActions
protected final PlainSchemaDAO	plainSchemaDAO
protected final ApplicationEventPublisher	publisher
protected final ExternalResourceDAO	resourceDAO
protected final Map<String,org.springframework.retry.support.RetryTemplate>	retryTemplates
protected final TaskDAO	taskDAO
protected final TaskDataBinder	taskDataBinder
protected final TaskUtilsFactory	taskUtilsFactory
protected final PlainAttrValidationManager	validator

Constructor Summary

Constructors

Constructor

Description

AbstractPropagationTaskExecutor(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)

Method Summary

Modifier and Type	Method	Description
protected void	checkMandatoryMissing(PropagationTaskInfo taskInfo, Set<Attribute> attrs, boolean enablePasswordCheck)
protected Uid	createOrUpdate(PropagationTaskInfo taskInfo, boolean fetchRemoteObj, ConnectorObject beforeObj, Connector connector, Mutable<Boolean> propagationAttempted)
protected Uid	delete(PropagationTaskInfo taskInfo, boolean fetchRemoteObj, ConnectorObject beforeObj, Connector connector, Mutable<Boolean> propagationAttempted)
protected Uid	doCreate(PropagationTaskInfo taskInfo, Connector connector, Mutable<Boolean> propagationAttempted)
protected TaskExec<PropagationTask>	doExecute(PropagationTaskInfo taskInfo, PropagationReporter reporter, String executor)
protected Uid	doUpdate(PropagationTaskInfo taskInfo, Connector connector, ConnectorObject beforeObj, Mutable<Boolean> propagationAttempted)
protected Uid	doUpdateDelta(PropagationTaskInfo taskInfo, Set<AttributeDelta> modifications, Connector connector, Mutable<Boolean> propagationAttempted)
TaskExec<PropagationTask>	execute(PropagationTaskInfo taskInfo, PropagationReporter reporter, String executor)	Execute the given task and returns the generated TaskExec.
void	expireRetryTemplate(String resource)	Remove any RetryTemplate defined for the given External Resource from local cache.
protected List<PropagationActions>	getPropagationActions(ExternalResource resource)
protected ConnectorObject	getRemoteObject(PropagationTaskInfo taskInfo, Connector connector, OrgUnit orgUnit, List<PropagationActions> actions, boolean latest)	Get remote object for given task.
protected ConnectorObject	getRemoteObject(PropagationTaskInfo taskInfo, Connector connector, Provision provision, List<PropagationActions> actions, boolean latest)	Get remote object for given task.
protected Optional<PropagationTask>	hasToBeregistered(PropagationTaskInfo taskInfo, TaskExec<PropagationTask> execution)	Check whether an execution has to be stored, for a given task.
protected boolean	isFetchRemoteObj(PropagationTaskInfo taskInfo)
protected TaskExec<PropagationTask>	rejected(PropagationTaskInfo taskInfo, String rejectReason, PropagationReporter reporter, String executor)
protected Optional<org.springframework.retry.support.RetryTemplate>	retryTemplate(ExternalResource resource)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.syncope.core.provisioning.api.propagation.PropagationTaskExecutor

execute

Field Details

LOG

protected static final Logger LOG

retryTemplates

protected final Map<String,org.springframework.retry.support.RetryTemplate> retryTemplates

connectorManager

protected final ConnectorManager connectorManager

connObjectUtils

protected final ConnObjectUtils connObjectUtils

taskDAO

protected final TaskDAO taskDAO

resourceDAO

protected final ExternalResourceDAO resourceDAO

plainSchemaDAO

protected final PlainSchemaDAO plainSchemaDAO

notificationManager

protected final NotificationManager notificationManager

auditManager

protected final AuditManager auditManager

taskDataBinder

protected final TaskDataBinder taskDataBinder

anyUtilsFactory

protected final AnyUtilsFactory anyUtilsFactory

taskUtilsFactory

protected final TaskUtilsFactory taskUtilsFactory

outboundMatcher

protected final OutboundMatcher outboundMatcher

validator

protected final PlainAttrValidationManager validator

publisher

protected final ApplicationEventPublisher publisher

perContextActions

protected final Map<String,PropagationActions> perContextActions

Constructor Details

AbstractPropagationTaskExecutor

public AbstractPropagationTaskExecutor(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)

Method Details

expireRetryTemplate

public void expireRetryTemplate(String resource)

Description copied from interface: PropagationTaskExecutor

Remove any RetryTemplate defined for the given External Resource from local cache.

Specified by:

expireRetryTemplate in interface PropagationTaskExecutor

Parameters:

resource - External Resource name

getPropagationActions

protected List<PropagationActions> getPropagationActions(ExternalResource resource)

checkMandatoryMissing

protected void checkMandatoryMissing(PropagationTaskInfo taskInfo,
 Set<Attribute> attrs,
 boolean enablePasswordCheck)

doCreate

protected Uid doCreate(PropagationTaskInfo taskInfo,
 Connector connector,
 Mutable<Boolean> propagationAttempted)

doUpdate

protected Uid doUpdate(PropagationTaskInfo taskInfo,
 Connector connector,
 ConnectorObject beforeObj,
 Mutable<Boolean> propagationAttempted)

doUpdateDelta

protected Uid doUpdateDelta(PropagationTaskInfo taskInfo,
 Set<AttributeDelta> modifications,
 Connector connector,
 Mutable<Boolean> propagationAttempted)

createOrUpdate

protected Uid createOrUpdate(PropagationTaskInfo taskInfo,
 boolean fetchRemoteObj,
 ConnectorObject beforeObj,
 Connector connector,
 Mutable<Boolean> propagationAttempted)

delete

protected Uid delete(PropagationTaskInfo taskInfo,
 boolean fetchRemoteObj,
 ConnectorObject beforeObj,
 Connector connector,
 Mutable<Boolean> propagationAttempted)

retryTemplate

protected Optional<org.springframework.retry.support.RetryTemplate> retryTemplate(ExternalResource resource)

execute

public TaskExec<PropagationTask> execute(PropagationTaskInfo taskInfo,
 PropagationReporter reporter,
 String executor)

Description copied from interface: PropagationTaskExecutor

Execute the given task and returns the generated TaskExec.

Specified by:

execute in interface PropagationTaskExecutor

Parameters:

taskInfo - to be executed

reporter - to report propagation execution status

executor - the executor of this task

Returns:

the generated TaskExec

isFetchRemoteObj

protected boolean isFetchRemoteObj(PropagationTaskInfo taskInfo)

doExecute

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

rejected

protected TaskExec<PropagationTask> rejected(PropagationTaskInfo taskInfo,
 String rejectReason,
 PropagationReporter reporter,
 String executor)

hasToBeregistered

protected Optional<PropagationTask> hasToBeregistered(PropagationTaskInfo taskInfo,
 TaskExec<PropagationTask> execution)

Check whether an execution has to be stored, for a given task.

Parameters:

taskInfo - propagation task

execution - to be decide whether to store or not

Returns:

true if execution has to be store, false otherwise

getRemoteObject

protected ConnectorObject getRemoteObject(PropagationTaskInfo taskInfo,
 Connector connector,
 Provision provision,
 List<PropagationActions> actions,
 boolean latest)

Get remote object for given task.

Parameters:

taskInfo - current propagation task

connector - connector facade proxy

provision - provision

actions - propagation actions

latest - 'FALSE' to retrieve object using old connObjectKey if not null.

Returns:

remote connector object.

getRemoteObject

protected ConnectorObject getRemoteObject(PropagationTaskInfo taskInfo,
 Connector connector,
 OrgUnit orgUnit,
 List<PropagationActions> actions,
 boolean latest)

Get remote object for given task.

Parameters:

taskInfo - current propagation task

connector - connector facade proxy

orgUnit - orgUnit

actions - propagation actions

latest - 'FALSE' to retrieve object using old connObjectKey if not null.

Returns:

remote connector object.