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

Class PullJobDelegate

java.lang.Object

org.apache.syncope.core.provisioning.java.job.AbstractSchedTaskJobDelegate<T>

org.apache.syncope.core.provisioning.java.pushpull.AbstractProvisioningJobDelegate<PullTask>

org.apache.syncope.core.provisioning.java.pushpull.PullJobDelegate

All Implemented Interfaces:

JobDelegate, SchedTaskJobDelegate, SyncopePullExecutor

Direct Known Subclasses:

SinglePullJobDelegate, StreamPullJobDelegate

public class PullJobDelegate
extends AbstractProvisioningJobDelegate<PullTask>
implements SyncopePullExecutor

Field Summary

Fields

Modifier and Type	Field	Description
protected AnyUtilsFactory	anyUtilsFactory
protected GroupDAO	groupDAO
protected Map<String,MutablePair<Integer,String>>	handled
protected InboundMatcher	inboundMatcher
protected Map<String,SyncToken>	latestSyncTokens
protected Map<String,PullActions>	perContextActions
protected Optional<ReconFilterBuilder>	perContextReconFilterBuilder
protected PlainSchemaDAO	plainSchemaDAO
protected ProvisioningProfile<PullTask,PullActions>	profile
protected PlainAttrValidationManager	validator
protected VirSchemaDAO	virSchemaDAO

Fields inherited from class org.apache.syncope.core.provisioning.java.pushpull.AbstractProvisioningJobDelegate

anyTypeDAO, connectorManager, entityFactory, perContextProvisionSorter, policyDAO, resourceDAO

Fields inherited from class org.apache.syncope.core.provisioning.java.job.AbstractSchedTaskJobDelegate

auditManager, interrupt, interrupted, LOG, notificationManager, publisher, securityProperties, task, taskDAO, taskDataBinder, taskExecDAO, taskType, taskUtilsFactory

Fields inherited from interface org.apache.syncope.core.provisioning.api.job.JobDelegate

OPERATION_ID

Constructor Summary

Constructors

Constructor	Description
PullJobDelegate()

Method Summary

Modifier and Type	Method	Description
protected AnyObjectPullResultHandler	buildAnyObjectHandler()
protected GroupPullResultHandler	buildGroupHandler()
protected RealmPullResultHandler	buildRealmHandler()
protected UserPullResultHandler	buildUserHandler()
protected String	doExecuteProvisioning(PullTask pullTask, Connector connector, boolean dryRun, String executor, org.quartz.JobExecutionContext context)
protected List<PullActions>	getPullActions(List<? extends Implementation> impls)
protected ReconFilterBuilder	getReconFilterBuilder(PullTask pullTask)
void	reportHandled(String objectClass, Name name)
protected void	setGroupOwners(GroupPullResultHandler ghandler)
void	setInterrupted()
void	setLatestSyncToken(String objectClass, SyncToken latestSyncToken)
boolean	wasInterruptRequested()

Methods inherited from class org.apache.syncope.core.provisioning.java.pushpull.AbstractProvisioningJobDelegate

createReport, doExecute, generate, getConnector, getProvisionSorter, getTaskClassReference, hasToBeRegistered

Methods inherited from class org.apache.syncope.core.provisioning.java.job.AbstractSchedTaskJobDelegate

execute, interrupt, isInterrupted, register, setStatus

Methods inherited from class java.lang.Object

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

Field Detail

groupDAO

@Autowired
protected GroupDAO groupDAO

plainSchemaDAO

@Autowired
protected PlainSchemaDAO plainSchemaDAO

virSchemaDAO

@Autowired
protected VirSchemaDAO virSchemaDAO

inboundMatcher

@Autowired
protected InboundMatcher inboundMatcher

anyUtilsFactory

@Autowired
protected AnyUtilsFactory anyUtilsFactory

validator

@Autowired
protected PlainAttrValidationManager validator

latestSyncTokens

protected final Map<String,SyncToken> latestSyncTokens

profile

protected ProvisioningProfile<PullTask,PullActions> profile

handled

protected final Map<String,MutablePair<Integer,String>> handled

perContextActions

protected final Map<String,PullActions> perContextActions

perContextReconFilterBuilder

protected Optional<ReconFilterBuilder> perContextReconFilterBuilder

Constructor Detail

PullJobDelegate

public PullJobDelegate()

Method Detail

setLatestSyncToken

public void setLatestSyncToken(String objectClass,
                               SyncToken latestSyncToken)

Specified by:

setLatestSyncToken in interface SyncopePullExecutor

reportHandled

public void reportHandled(String objectClass,
                          Name name)

Specified by:

reportHandled in interface SyncopePullExecutor

wasInterruptRequested

public boolean wasInterruptRequested()

Specified by:

wasInterruptRequested in interface SyncopePullExecutor

setInterrupted

public void setInterrupted()

Specified by:

setInterrupted in interface SyncopePullExecutor

setGroupOwners

protected void setGroupOwners(GroupPullResultHandler ghandler)

getPullActions

protected List<PullActions> getPullActions(List<? extends Implementation> impls)

getReconFilterBuilder

protected ReconFilterBuilder getReconFilterBuilder(PullTask pullTask)
                                            throws ClassNotFoundException

Throws:

ClassNotFoundException

buildRealmHandler

protected RealmPullResultHandler buildRealmHandler()

buildAnyObjectHandler

protected AnyObjectPullResultHandler buildAnyObjectHandler()

buildUserHandler

protected UserPullResultHandler buildUserHandler()

buildGroupHandler

protected GroupPullResultHandler buildGroupHandler()

doExecuteProvisioning

protected String doExecuteProvisioning(PullTask pullTask,
                                       Connector connector,
                                       boolean dryRun,
                                       String executor,
                                       org.quartz.JobExecutionContext context)
                                throws org.quartz.JobExecutionException

Specified by:

doExecuteProvisioning in class AbstractProvisioningJobDelegate<PullTask>

Throws:

org.quartz.JobExecutionException