public class PullJobDelegate extends AbstractProvisioningJobDelegate<PullTask> implements SyncopePullExecutor
Modifier and Type | Field and Description |
---|---|
protected AnyUtilsFactory |
anyUtilsFactory |
protected GroupDAO |
groupDAO |
protected Map<ObjectClass,MutablePair<Integer,String>> |
handled |
protected InboundMatcher |
inboundMatcher |
protected Map<ObjectClass,SyncToken> |
latestSyncTokens |
protected Map<String,PullActions> |
perContextActions |
protected Optional<ReconFilterBuilder> |
perContextReconFilterBuilder |
protected ProvisioningProfile<PullTask,PullActions> |
profile |
protected PlainAttrValidationManager |
validator |
protected VirSchemaDAO |
virSchemaDAO |
adminUser, anyTypeDAO, connFactory, perContextProvisionSorter, policyDAO, resourceDAO
auditManager, entityFactory, interrupt, interrupted, LOG, notificationManager, publisher, task, taskDAO, taskDataBinder, taskExecDAO
Constructor and Description |
---|
PullJobDelegate() |
Modifier and Type | Method and Description |
---|---|
protected AnyObjectPullResultHandler |
buildAnyObjectHandler() |
protected GroupPullResultHandler |
buildGroupHandler() |
protected RealmPullResultHandler |
buildRealmHandler() |
protected UserPullResultHandler |
buildUserHandler() |
protected String |
doExecuteProvisioning(PullTask pullTask,
Connector connector,
boolean dryRun,
org.quartz.JobExecutionContext context) |
protected List<PullActions> |
getPullActions(List<? extends Implementation> impls) |
protected ReconFilterBuilder |
getReconFilterBuilder(PullTask pullTask) |
void |
reportHandled(ObjectClass objectClass,
Name name) |
protected void |
setGroupOwners(GroupPullResultHandler ghandler) |
void |
setInterrupted() |
void |
setLatestSyncToken(ObjectClass objectClass,
SyncToken latestSyncToken) |
boolean |
wasInterruptRequested() |
createReport, doExecute, generate, getConnector, getProvisionSorter, getTaskClassReference, hasToBeRegistered
execute, interrupt, isInterrupted, register, setStatus
@Autowired protected GroupDAO groupDAO
@Autowired protected VirSchemaDAO virSchemaDAO
@Autowired protected InboundMatcher inboundMatcher
@Autowired protected AnyUtilsFactory anyUtilsFactory
@Autowired protected PlainAttrValidationManager validator
protected final Map<ObjectClass,SyncToken> latestSyncTokens
protected final Map<ObjectClass,MutablePair<Integer,String>> handled
protected final Map<String,PullActions> perContextActions
protected Optional<ReconFilterBuilder> perContextReconFilterBuilder
protected ProvisioningProfile<PullTask,PullActions> profile
public void setLatestSyncToken(ObjectClass objectClass, SyncToken latestSyncToken)
setLatestSyncToken
in interface SyncopePullExecutor
public void reportHandled(ObjectClass objectClass, Name name)
reportHandled
in interface SyncopePullExecutor
public boolean wasInterruptRequested()
wasInterruptRequested
in interface SyncopePullExecutor
public void setInterrupted()
setInterrupted
in interface SyncopePullExecutor
protected void setGroupOwners(GroupPullResultHandler ghandler)
protected List<PullActions> getPullActions(List<? extends Implementation> impls)
protected ReconFilterBuilder getReconFilterBuilder(PullTask pullTask) throws ClassNotFoundException
ClassNotFoundException
protected RealmPullResultHandler buildRealmHandler()
protected AnyObjectPullResultHandler buildAnyObjectHandler()
protected UserPullResultHandler buildUserHandler()
protected GroupPullResultHandler buildGroupHandler()
protected String doExecuteProvisioning(PullTask pullTask, Connector connector, boolean dryRun, org.quartz.JobExecutionContext context) throws org.quartz.JobExecutionException
doExecuteProvisioning
in class AbstractProvisioningJobDelegate<PullTask>
org.quartz.JobExecutionException
Copyright © 2010–2023 The Apache Software Foundation. All rights reserved.