@Transactional(rollbackFor=java.lang.Throwable.class) public abstract class AbstractPullResultHandler extends AbstractSyncopeResultHandler<PullTask,PullActions> implements SyncopePullResultHandler
Modifier and Type | Field and Description |
---|---|
protected AnyTypeDAO |
anyTypeDAO |
protected AuditManager |
auditManager |
protected ConnObjectUtils |
connObjectUtils |
protected EntityFactory |
entityFactory |
protected SyncopePullExecutor |
executor |
protected InboundMatcher |
inboundMatcher |
protected AuditElements.Result |
latestResult |
protected NotificationManager |
notificationManager |
protected RemediationDAO |
remediationDAO |
protected TaskDAO |
taskDAO |
protected UserDAO |
userDAO |
protected VirAttrCache |
virAttrCache |
protected VirSchemaDAO |
virSchemaDAO |
anyObjectDataBinder, anyUtilsFactory, awfAdapter, groupDataBinder, gwfAdapter, LOG, profile, propagationManager, taskExecutor, userDataBinder, uwfAdapter
Constructor and Description |
---|
AbstractPullResultHandler() |
Modifier and Type | Method and Description |
---|---|
protected void |
createRemediation(AnyType anyType,
AnyPatch anyPatch,
PullTask pullTask,
ProvisioningReport result,
SyncDelta delta) |
protected void |
createRemediation(AnyType anyType,
String anyKey,
AnyTO anyTO,
AnyPatch anyPatch,
PullTask pullTask,
ProvisioningReport result,
SyncDelta delta) |
protected void |
createRemediationIfNeeded(AnyPatch anyPatch,
SyncDelta delta,
ProvisioningReport result) |
protected List<ProvisioningReport> |
delete(SyncDelta delta,
List<PullMatch> matches,
Provision provision) |
protected List<ProvisioningReport> |
deprovision(MatchingRule matchingRule,
SyncDelta delta,
List<PullMatch> matches,
Provision provision) |
protected abstract AnyTO |
doCreate(AnyTO anyTO,
SyncDelta delta) |
protected void |
doHandle(SyncDelta delta,
Provision provision)
Look into SyncDelta and take necessary profile.getActions() (create / update / delete) on any object(s).
|
protected abstract AnyPatch |
doUpdate(AnyTO before,
AnyPatch anyPatch,
SyncDelta delta,
ProvisioningReport result) |
protected void |
end(AnyTypeKind anyTypeKind,
String event,
AuditElements.Result result,
Object before,
Object output,
SyncDelta delta,
Object... furtherInput) |
protected abstract String |
getName(AnyTO anyTO) |
protected abstract ProvisioningManager<?,?> |
getProvisioningManager() |
boolean |
handle(SyncDelta delta) |
protected void |
handleAnys(SyncDelta delta,
List<PullMatch> matches,
Provision provision) |
protected void |
handleLinkedAccounts(SyncDelta delta,
List<PullMatch> matches,
Provision provision) |
protected List<ProvisioningReport> |
ignore(SyncDelta delta,
List<PullMatch> matches,
Provision provision,
boolean matching,
String... message) |
protected List<ProvisioningReport> |
link(SyncDelta delta,
List<PullMatch> matches,
Provision provision,
boolean unlink) |
protected List<ProvisioningReport> |
provision(UnmatchingRule rule,
SyncDelta delta,
Provision provision) |
void |
setPullExecutor(SyncopePullExecutor executor) |
protected void |
throwIgnoreProvisionException(SyncDelta delta,
Exception exception) |
protected List<ProvisioningReport> |
update(SyncDelta delta,
List<PullMatch> matches,
Provision provision) |
getAnyTO, getAnyUtils, getProfile, setProfile, update
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getProfile, setProfile
@Autowired protected InboundMatcher inboundMatcher
@Autowired protected NotificationManager notificationManager
@Autowired protected AuditManager auditManager
@Autowired protected ConnObjectUtils connObjectUtils
@Autowired protected UserDAO userDAO
@Autowired protected AnyTypeDAO anyTypeDAO
@Autowired protected TaskDAO taskDAO
@Autowired protected RemediationDAO remediationDAO
@Autowired protected VirSchemaDAO virSchemaDAO
@Autowired protected VirAttrCache virAttrCache
@Autowired protected EntityFactory entityFactory
protected SyncopePullExecutor executor
protected AuditElements.Result latestResult
protected abstract ProvisioningManager<?,?> getProvisioningManager()
protected abstract AnyPatch doUpdate(AnyTO before, AnyPatch anyPatch, SyncDelta delta, ProvisioningReport result)
public void setPullExecutor(SyncopePullExecutor executor)
setPullExecutor
in interface SyncopePullResultHandler
public boolean handle(SyncDelta delta)
handle
in interface SyncopePullResultHandler
handle
in interface SyncResultsHandler
protected List<ProvisioningReport> provision(UnmatchingRule rule, SyncDelta delta, Provision provision) throws org.quartz.JobExecutionException
org.quartz.JobExecutionException
protected void throwIgnoreProvisionException(SyncDelta delta, Exception exception) throws org.quartz.JobExecutionException
org.quartz.JobExecutionException
protected List<ProvisioningReport> update(SyncDelta delta, List<PullMatch> matches, Provision provision) throws org.quartz.JobExecutionException
org.quartz.JobExecutionException
protected List<ProvisioningReport> deprovision(MatchingRule matchingRule, SyncDelta delta, List<PullMatch> matches, Provision provision) throws org.quartz.JobExecutionException
org.quartz.JobExecutionException
protected List<ProvisioningReport> link(SyncDelta delta, List<PullMatch> matches, Provision provision, boolean unlink) throws org.quartz.JobExecutionException
org.quartz.JobExecutionException
protected List<ProvisioningReport> delete(SyncDelta delta, List<PullMatch> matches, Provision provision) throws org.quartz.JobExecutionException
org.quartz.JobExecutionException
protected List<ProvisioningReport> ignore(SyncDelta delta, List<PullMatch> matches, Provision provision, boolean matching, String... message) throws org.quartz.JobExecutionException
org.quartz.JobExecutionException
protected void handleAnys(SyncDelta delta, List<PullMatch> matches, Provision provision) throws org.quartz.JobExecutionException
org.quartz.JobExecutionException
protected void handleLinkedAccounts(SyncDelta delta, List<PullMatch> matches, Provision provision) throws org.quartz.JobExecutionException
org.quartz.JobExecutionException
protected void doHandle(SyncDelta delta, Provision provision) throws org.quartz.JobExecutionException
delta
- returned by the underlying profile.getConnector()provision
- provisioning infoorg.quartz.JobExecutionException
- in case of pull failure.protected void end(AnyTypeKind anyTypeKind, String event, AuditElements.Result result, Object before, Object output, SyncDelta delta, Object... furtherInput)
protected void createRemediationIfNeeded(AnyPatch anyPatch, SyncDelta delta, ProvisioningReport result)
protected void createRemediation(AnyType anyType, AnyPatch anyPatch, PullTask pullTask, ProvisioningReport result, SyncDelta delta)
Copyright © 2010–2023 The Apache Software Foundation. All rights reserved.