@Transactional(rollbackFor=java.lang.Throwable.class) public abstract class AbstractPropagationTaskExecutor extends Object implements PropagationTaskExecutor
Modifier and Type | Field and Description |
---|---|
protected AnyObjectDAO |
anyObjectDAO
Any object DAO.
|
protected AnyUtilsFactory |
anyUtilsFactory |
protected AuditManager |
auditManager
Audit Manager.
|
protected ConnectorFactory |
connFactory
Connector factory.
|
protected ConnObjectUtils |
connObjectUtils
ConnObjectUtils.
|
protected EntityFactory |
entityFactory |
protected GroupDAO |
groupDAO
Group DAO.
|
protected static org.slf4j.Logger |
LOG |
protected NotificationManager |
notificationManager
Notification Manager.
|
protected OutboundMatcher |
outboundMatcher |
protected ApplicationEventPublisher |
publisher |
protected ExternalResourceDAO |
resourceDAO |
protected Map<String,org.springframework.retry.support.RetryTemplate> |
retryTemplates |
protected TaskDAO |
taskDAO
Task DAO.
|
protected TaskDataBinder |
taskDataBinder
Task data binder.
|
protected TaskUtilsFactory |
taskUtilsFactory |
protected UserDAO |
userDAO
User DAO.
|
protected PlainAttrValidationManager |
validator |
MANDATORY_MISSING_ATTR_NAME, MANDATORY_NULL_OR_EMPTY_ATTR_NAME
Constructor and Description |
---|
AbstractPropagationTaskExecutor() |
Modifier and Type | Method and Description |
---|---|
protected PropagationTask |
buildTask(PropagationTaskInfo taskInfo) |
protected Uid |
createOrUpdate(PropagationTask task,
ConnectorObject beforeObj,
Connector connector,
AtomicReference<Boolean> propagationAttempted) |
protected Uid |
delete(PropagationTask task,
ConnectorObject beforeObj,
Connector connector,
AtomicReference<Boolean> propagationAttempted) |
protected TaskExec |
doExecute(PropagationTaskInfo taskInfo,
PropagationTask task,
PropagationReporter reporter) |
TaskExec |
execute(PropagationTaskInfo taskInfo,
PropagationReporter reporter)
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(PropagationTask task,
Connector connector,
OrgUnit orgUnit,
List<PropagationActions> actions,
boolean latest)
Get remote object for given task.
|
protected ConnectorObject |
getRemoteObject(PropagationTask task,
Connector connector,
Provision provision,
List<PropagationActions> actions,
boolean latest)
Get remote object for given task.
|
protected boolean |
hasToBeregistered(PropagationTask task,
TaskExec execution)
Check whether an execution has to be stored, for a given task.
|
protected TaskExec |
rejected(PropagationTaskInfo taskInfo,
String rejectReason,
PropagationReporter reporter) |
protected Optional<org.springframework.retry.support.RetryTemplate> |
retryTemplate(ExternalResource resource) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
execute
protected static final org.slf4j.Logger LOG
protected final Map<String,org.springframework.retry.support.RetryTemplate> retryTemplates
@Autowired protected ConnectorFactory connFactory
@Autowired protected ConnObjectUtils connObjectUtils
@Autowired protected UserDAO userDAO
@Autowired protected GroupDAO groupDAO
@Autowired protected AnyObjectDAO anyObjectDAO
@Autowired protected TaskDAO taskDAO
@Autowired protected ExternalResourceDAO resourceDAO
@Autowired protected NotificationManager notificationManager
@Autowired protected AuditManager auditManager
@Autowired protected TaskDataBinder taskDataBinder
@Autowired protected AnyUtilsFactory anyUtilsFactory
@Autowired protected TaskUtilsFactory taskUtilsFactory
@Autowired protected EntityFactory entityFactory
@Autowired protected OutboundMatcher outboundMatcher
@Autowired protected PlainAttrValidationManager validator
@Autowired protected ApplicationEventPublisher publisher
public void expireRetryTemplate(String resource)
PropagationTaskExecutor
expireRetryTemplate
in interface PropagationTaskExecutor
resource
- External Resource nameprotected List<PropagationActions> getPropagationActions(ExternalResource resource)
protected Uid createOrUpdate(PropagationTask task, ConnectorObject beforeObj, Connector connector, AtomicReference<Boolean> propagationAttempted)
protected Uid delete(PropagationTask task, ConnectorObject beforeObj, Connector connector, AtomicReference<Boolean> propagationAttempted)
protected PropagationTask buildTask(PropagationTaskInfo taskInfo)
protected Optional<org.springframework.retry.support.RetryTemplate> retryTemplate(ExternalResource resource)
public TaskExec execute(PropagationTaskInfo taskInfo, PropagationReporter reporter)
PropagationTaskExecutor
TaskExec
.execute
in interface PropagationTaskExecutor
taskInfo
- to be executedreporter
- to report propagation execution statusprotected TaskExec doExecute(PropagationTaskInfo taskInfo, PropagationTask task, PropagationReporter reporter)
protected TaskExec rejected(PropagationTaskInfo taskInfo, String rejectReason, PropagationReporter reporter)
protected boolean hasToBeregistered(PropagationTask task, TaskExec execution)
task
- propagation taskexecution
- to be decide whether to store or notprotected ConnectorObject getRemoteObject(PropagationTask task, Connector connector, Provision provision, List<PropagationActions> actions, boolean latest)
connector
- connector facade proxy.task
- current propagation task.provision
- provisionactions
- propagation actionslatest
- 'FALSE' to retrieve object using old connObjectKey if not null.protected ConnectorObject getRemoteObject(PropagationTask task, Connector connector, OrgUnit orgUnit, List<PropagationActions> actions, boolean latest)
connector
- connector facade proxy.task
- current propagation task.orgUnit
- orgUnitactions
- propagation actionslatest
- 'FALSE' to retrieve object using old connObjectKey if not null.Copyright © 2010–2023 The Apache Software Foundation. All rights reserved.